Method Create

pkg/session/sqlite/store.go:107–137

Create creates a new session.

(ctx context.Context, req *session.CreateRequest)

// Create creates a new session.
func (s *Service) Create(ctx context.Context, req *session.CreateRequest) (session.Session, error) {
	s.mu.Lock()
	defer s.mu.Unlock()

	id := uuid.New().String()
	now := time.Now()

	metadata, err := json.Marshal(req.Metadata)
	if err != nil {
		return nil, fmt.Errorf("marshal metadata: %w", err)
	}

	_, err = s.db.ExecContext(ctx,
		`INSERT INTO sessions (id, app_name, user_id, agent_id, metadata, created_at, updated_at)
		 VALUES (?, ?, ?, ?, ?, ?, ?)`,
		id, req.AppName, req.UserID, req.AgentID, string(metadata), now, now,
	)
	if err != nil {
		return nil, fmt.Errorf("insert session: %w", err)
	}

	return &sqliteSession{
		service:        s,
		id:             id,
		appName:        req.AppName,
		userID:         req.UserID,
		agentID:        req.AgentID,
		metadata:       req.Metadata,
		lastUpdateTime: now,
	}, nil
}

// Get retrieves a session by ID.
func (s *Service) Get(ctx context.Context, req *session.GetRequest) (session.Session, error) {