summaryrefslogtreecommitdiff
path: root/srv
diff options
context:
space:
mode:
authorBrian Picciano <mediocregopher@gmail.com>2021-08-08 09:07:51 -0600
committerBrian Picciano <mediocregopher@gmail.com>2021-08-08 09:07:51 -0600
commitca27cd6c677f5effe7b08639a8db92371065b4e3 (patch)
tree56e84757b9a77852bea850c934e777ec719d6ef7 /srv
parent6feffc568ae790a883b9e0509d755e7d9bd82ee1 (diff)
get a basic mailinglist-cli working
Diffstat (limited to 'srv')
-rw-r--r--srv/cmd/mailinglist-cli/main.go100
-rw-r--r--srv/default.nix13
2 files changed, 110 insertions, 3 deletions
diff --git a/srv/cmd/mailinglist-cli/main.go b/srv/cmd/mailinglist-cli/main.go
new file mode 100644
index 0000000..ca4ccd6
--- /dev/null
+++ b/srv/cmd/mailinglist-cli/main.go
@@ -0,0 +1,100 @@
+package main
+
+import (
+ "context"
+ "errors"
+ "fmt"
+ "io"
+ "path"
+
+ "github.com/mediocregopher/blog.mediocregopher.com/srv/cfg"
+ "github.com/mediocregopher/blog.mediocregopher.com/srv/mailinglist"
+ "github.com/mediocregopher/mediocre-go-lib/v2/mctx"
+ "github.com/mediocregopher/mediocre-go-lib/v2/mlog"
+ "github.com/tilinna/clock"
+)
+
+func loggerFatalErr(ctx context.Context, logger *mlog.Logger, descr string, err error) {
+ logger.Fatal(ctx, fmt.Sprintf("%s: %v", descr, err))
+}
+
+func main() {
+ ctx := context.Background()
+ cfg := cfg.New()
+
+ dataDir := cfg.String("data-dir", ".", "Directory to use for long term storage")
+
+ var mailerParams mailinglist.MailerParams
+ mailerParams.SetupCfg(cfg)
+ ctx = mctx.WithAnnotator(ctx, &mailerParams)
+
+ var mlParams mailinglist.Params
+ mlParams.SetupCfg(cfg)
+ ctx = mctx.WithAnnotator(ctx, &mlParams)
+
+ // initialization
+ err := cfg.Init(ctx)
+
+ logger := mlog.NewLogger(nil)
+ defer logger.Close()
+
+ logger.Info(ctx, "process started")
+ defer logger.Info(ctx, "process exiting")
+
+ if err != nil {
+ loggerFatalErr(ctx, logger, "initializing", err)
+ }
+
+ clock := clock.Realtime()
+
+ var mailer mailinglist.Mailer
+ if mailerParams.SMTPAddr == "" {
+ logger.Info(ctx, "-smtp-addr not given, using NullMailer")
+ mailer = mailinglist.NullMailer
+ } else {
+ mailer = mailinglist.NewMailer(mailerParams)
+ }
+
+ mlStore, err := mailinglist.NewStore(path.Join(*dataDir, "mailinglist.sqlite3"))
+ if err != nil {
+ loggerFatalErr(ctx, logger, "initializing mailing list storage", err)
+ }
+ defer mlStore.Close()
+
+ mlParams.Store = mlStore
+ mlParams.Mailer = mailer
+ mlParams.Clock = clock
+
+ ml := mailinglist.New(mlParams)
+ _ = ml
+
+ args := cfg.Args()
+ if len(args) == 0 {
+ args = append(args, "")
+ }
+
+ action, args := args[0], args[1:]
+
+ switch action {
+ case "list":
+ for it := mlStore.GetAll(); ; {
+ email, err := it()
+ if errors.Is(err, io.EOF) {
+ break
+ } else if err != nil {
+ loggerFatalErr(ctx, logger, "retrieving next email", err)
+ }
+
+ ctx := mctx.Annotate(context.Background(),
+ "email", email.Email,
+ "createdAt", email.CreatedAt,
+ "verifiedAt", email.VerifiedAt,
+ )
+
+ logger.Info(ctx, "next")
+ }
+
+ default:
+ logger.Fatal(ctx, "invalid action")
+ }
+}
diff --git a/srv/default.nix b/srv/default.nix
index 8a12f33..d7a80f7 100644
--- a/srv/default.nix
+++ b/srv/default.nix
@@ -1,11 +1,14 @@
{pkgs, config, staticBuild}: rec {
- opts = [
- "-pow-secret=${config.powSecret}"
+ mailingListOpts = [
"-ml-smtp-addr=${config.mlSMTPAddr}"
"-ml-smtp-auth='${config.mlSMTPAuth}'"
"-data-dir=${config.dataDir}"
"-public-url=${config.publicURL}"
+ ];
+
+ opts = mailingListOpts ++ [
+ "-pow-secret=${config.powSecret}"
"-listen-proto=${config.listenProto}"
"-listen-addr=${config.listenAddr}"
] ++ (
@@ -30,9 +33,13 @@
go run ./cmd/mediocre-blog/main.go ${toString opts}
'';
+ runMailingListCLIScript = pkgs.writeScriptBin "run-mailinglist-cli" ''
+ go run ./cmd/mailinglist-cli/main.go ${toString mailingListOpts} $@
+ '';
+
shell = pkgs.stdenv.mkDerivation {
name = "mediocre-blog-srv-shell";
- buildInputs = [ pkgs.go runScript ];
+ buildInputs = [ pkgs.go runScript runMailingListCLIScript ];
};
}