package common

import "database/sql"
import "../query_gen/lib"

var Subscriptions SubscriptionStore

// ? Should we have a subscription store for each zone? topic, forum, etc?
type SubscriptionStore interface {
	Add(uid int, elementID int, elementType string) error
}

type DefaultSubscriptionStore struct {
	add *sql.Stmt
}

func NewDefaultSubscriptionStore() (*DefaultSubscriptionStore, error) {
	acc := qgen.Builder.Accumulator()
	return &DefaultSubscriptionStore{
		add: acc.Insert("activity_subscriptions").Columns("user, targetID, targetType, level").Fields("?,?,?,2").Prepare(),
	}, acc.FirstError()
}

func (store *DefaultSubscriptionStore) Add(uid int, elementID int, elementType string) error {
	_, err := store.add.Exec(uid, elementID, elementType)
	return err
}