24 lines
433 B
Go
24 lines
433 B
Go
package repository
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/aykhans/oh-my-chat/internal/core/domain"
|
|
"github.com/gocql/gocql"
|
|
)
|
|
|
|
type MessageRepository struct {
|
|
db *gocql.Session
|
|
}
|
|
|
|
func NewMessageRepository(db *gocql.Session) *MessageRepository {
|
|
return &MessageRepository{db}
|
|
}
|
|
|
|
func (messageRepository *MessageRepository) CreateMessage(
|
|
ctx context.Context,
|
|
message *domain.Message,
|
|
) (*domain.Message, error) {
|
|
return nil, nil
|
|
}
|