package repositories

import (
	"context"
	"primesys_command_producer/src/db"
	"primesys_command_producer/src/models"
	"time"
)

const commandHistoryCollection = "command_history"

func InsertCommandHistory(ctx context.Context, cmd *models.CommandHistory) error {
	// TTL index (expireAfterSeconds) counts from this time
	cmd.TTLTimestamp = time.Now()
	_, err := db.Database().Collection(commandHistoryCollection).InsertOne(ctx, cmd)
	return err
}