diff options
| -rw-r--r-- | src/cracha.go | 40 |
1 files changed, 22 insertions, 18 deletions
diff --git a/src/cracha.go b/src/cracha.go index e9ef266..dc4193c 100644 --- a/src/cracha.go +++ b/src/cracha.go @@ -12,9 +12,9 @@ import ( "sync" "time" + "fiinha" "golite" "guuid" - "q" "scrypt" g "gobang" ) @@ -101,11 +101,11 @@ type Session struct{ type consumerT struct{ topic string - handlerFn func(authT) func(q.Message) error + handlerFn func(authT) func(fiinha.Message) error } type authT struct{ - queue q.IQueue + queue fiinha.IQueue db *sql.DB queries queriesT hasher func(scrypt.HashInput) ([]byte, error) @@ -1025,20 +1025,20 @@ func initDB( }, nil } -func newUserHandler(auth authT) func(q.Message) error { - return func(message q.Message) error { +func newUserHandler(auth authT) func(fiinha.Message) error { + return func(message fiinha.Message) error { return nil } } -func sendConfirmationRequestHandler(auth authT) func(q.Message) error { - return func(message q.Message) error { +func sendConfirmationRequestHandler(auth authT) func(fiinha.Message) error { + return func(message fiinha.Message) error { return nil } } -func forgotPasswordRequestHandler(auth authT) func(q.Message) error { - return func(message q.Message) error { +func forgotPasswordRequestHandler(auth authT) func(fiinha.Message) error { + return func(message fiinha.Message) error { return nil } } @@ -1072,7 +1072,11 @@ func registerConsumers(auth authT, consumers []consumerT, prefix string) error { return nil } -func unregisterConsumers(queue q.IQueue, consumers []consumerT, prefix string) { +func unregisterConsumers( + queue fiinha.IQueue, + consumers []consumerT, + prefix string, +) { for _, consumer := range consumers { queue.Unsubscribe(consumer.topic, prefix + "-" + consumer.topic) } @@ -1170,7 +1174,7 @@ func unwrapResult[A any, B any](fn func(A) resultT[B]) func(A) (B, error) { } func NewWithPrefix(databasePath string, prefix string) (IAuth, error) { - queue, err := q.New(databasePath) + queue, err := fiinha.New(databasePath) if err != nil { return authT{}, err } @@ -1274,7 +1278,7 @@ func (auth authT) Register( return User{}, err } - unsent := q.UnsentMessage{ + unsent := fiinha.UnsentMessage{ Topic: NEW_USER, FlowID: flowID, Payload: payload, @@ -1298,15 +1302,15 @@ func (auth authT) Register( func sendConfirmationMessage( email string, flowID guuid.UUID, -) (q.UnsentMessage, error) { +) (fiinha.UnsentMessage, error) { data := make(map[string]interface{}) data["email"] = email payload, err := json.Marshal(data) if err != nil { - return q.UnsentMessage{}, err + return fiinha.UnsentMessage{}, err } - return q.UnsentMessage{ + return fiinha.UnsentMessage{ Topic: SEND_CONFIRMATION_REQUEST, FlowID: flowID, Payload: payload, @@ -1393,15 +1397,15 @@ func (auth authT) LoginEmail( func forgotPasswordMessage( email string, flowID guuid.UUID, -) (q.UnsentMessage, error) { +) (fiinha.UnsentMessage, error) { data := make(map[string]interface{}) data["email"] = email payload, err := json.Marshal(data) if err != nil { - return q.UnsentMessage{}, err + return fiinha.UnsentMessage{}, err } - return q.UnsentMessage{ + return fiinha.UnsentMessage{ Topic: FORGOT_PASSWORD_REQUEST, FlowID: flowID, Payload: payload, |