ca3-service.go

// WebSocketService implements the core logic of svc-ws.
type WebSocketService struct {
	client     *Client
	repository *Repository
}

func NewWebSocketService(client *Client, repository *Repository) *WebSocketService {
	return &WebSocketService{
		client:     client,
		repository: repository,
	}
}

// Connect saves a reference to connID in the datastore.
func (s *WebSocketService) Connect(ctx context.Context, connID string) (Response, error) {
	// save connection initially without username
	if err := s.repository.SaveConnection(ctx, connID, ""); err != nil {
		return ResponseInternalServerError(), fmt.Errorf("failed to connect connectionID %s: %w", connID, err)
	}
	return ResponseOK(), nil
}