summaryrefslogtreecommitdiff
path: root/internal/server/server.go
diff options
context:
space:
mode:
authorKyren223 <Kyren223@proton.me>2025-01-09 19:14:05 +0200
committerKyren223 <Kyren223@proton.me>2025-01-09 19:14:05 +0200
commitb09a8fba647ff030b24d9ad12215ba330c13080c (patch)
treed2be54859c70a6760edb75e26ee44299b17f50dc /internal/server/server.go
parent936d3cf690ace9adfdfe0fb44193c11a0cb26d95 (diff)
Fixed everything on the server-side
Diffstat (limited to 'internal/server/server.go')
-rw-r--r--internal/server/server.go13
1 files changed, 9 insertions, 4 deletions
diff --git a/internal/server/server.go b/internal/server/server.go
index 56c3a50..9abf51f 100644
--- a/internal/server/server.go
+++ b/internal/server/server.go
@@ -332,14 +332,16 @@ func processRequest(ctx context.Context, sess *session.Session, request packet.P
// Potentially even separate time for code vs DB operations
var response packet.Payload
switch request := request.(type) {
+
+ case *packet.SetUserData:
+ response = timeout(5*time.Millisecond, api.SetUserData, ctx, sess, request)
+ case *packet.GetUserData:
+ response = timeout(5*time.Millisecond, api.GetUserData, ctx, sess, request)
+
case *packet.CreateNetwork:
response = timeout(10*time.Millisecond, api.CreateNetwork, ctx, sess, request)
case *packet.DeleteNetwork:
response = timeout(500*time.Millisecond, api.DeleteNetwork, ctx, sess, request)
- case *packet.SwapUserNetworks:
- response = timeout(5*time.Millisecond, api.SwapUserNetworks, ctx, sess, request)
- case *packet.SetMember:
- response = timeout(50*time.Millisecond, api.SetMember, ctx, sess, request)
case *packet.CreateFrequency:
response = timeout(5*time.Millisecond, api.CreateFrequency, ctx, sess, request)
@@ -353,6 +355,9 @@ func processRequest(ctx context.Context, sess *session.Session, request packet.P
case *packet.RequestMessages:
response = timeout(50*time.Millisecond, api.RequestMessages, ctx, sess, request)
+ case *packet.SetMember:
+ response = timeout(50*time.Millisecond, api.SetMember, ctx, sess, request)
+
default:
response = &packet.Error{Error: "use of disallowed packet type for request"}
}