server/app/msg/internal/data/message.go

package data

import (
	"context"
	"w303a/server/app/msg/internal/biz"
	"w303a/server/pkg/zaplog"
)

var messageIncrementIdKey = "message.incr-id"

var _ biz.MessageRepo = (*messageRepo)(nil)

type messageRepo struct {
	log  *zaplog.Logger
	data *Data
}

func NewMessageRepo(data *Data, log *zaplog.Logger) biz.MessageRepo {
	return &messageRepo{
		data: data,
		log:  log,
	}
}

// IncrementMessageId implements the biz.MessageRepo interface.
func (repo *messageRepo) IncrementMessageId(ctx context.Context) (int64, error) {
	id, err := repo.data.redis.Incr(ctx, messageIncrementIdKey).Result()
	if err != nil {
		return 0, err
	}
	return id, nil
}