Delete 实现 session.Service 接口
(ctx context.Context, sessionID string)
| 193 | |
| 194 | // Delete 实现 session.Service 接口 |
| 195 | func (s *Service) Delete(ctx context.Context, sessionID string) error { |
| 196 | result := s.db.WithContext(ctx).Delete(&SessionModel{}, "id = ?", sessionID) |
| 197 | if result.Error != nil { |
| 198 | return fmt.Errorf("delete session: %w", result.Error) |
| 199 | } |
| 200 | if result.RowsAffected == 0 { |
| 201 | return session.ErrSessionNotFound |
| 202 | } |
| 203 | return nil |
| 204 | } |
| 205 | |
| 206 | // AppendEvent 实现 session.Service 接口 |
| 207 | func (s *Service) AppendEvent(ctx context.Context, sessionID string, event *session.Event) error { |