39 lines
1.1 KiB
Go
39 lines
1.1 KiB
Go
package api
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"net/http"
|
|
|
|
"github.com/aarondl/opt/omit"
|
|
"github.com/mattn/go-sqlite3"
|
|
"github.com/tigorlazuardi/redmage/models"
|
|
"github.com/tigorlazuardi/redmage/pkg/errs"
|
|
)
|
|
|
|
func (api *API) SubredditsCreate(ctx context.Context, params *models.Subreddit) (subreddit *models.Subreddit, err error) {
|
|
ctx, span := tracer.Start(ctx, "*API.SubredditsCreate")
|
|
defer span.End()
|
|
|
|
set := &models.SubredditSetter{
|
|
Name: omit.From(params.Name),
|
|
EnableSchedule: omit.From(params.EnableSchedule),
|
|
Subtype: omit.From(params.Subtype),
|
|
Schedule: omit.From(params.Schedule),
|
|
Countback: omit.From(params.Countback),
|
|
}
|
|
|
|
subreddit, err = models.Subreddits.Insert(ctx, api.db, set)
|
|
if err != nil {
|
|
var sqliteErr sqlite3.Error
|
|
if errors.As(err, &sqliteErr) {
|
|
if sqliteErr.Code == sqlite3.ErrConstraint {
|
|
return subreddit, errs.Wrapw(err, "subreddit with that name already exists", "set", set).Code(http.StatusConflict)
|
|
}
|
|
return subreddit, errs.Wrapw(err, "failed to create subreddit", "set", set)
|
|
}
|
|
}
|
|
|
|
return subreddit, nil
|
|
}
|