A tool for backing up ATProto related data to S3

make sure to call the knot code

Signed-off-by: Will Andrews <will7989@hotmail.com>

Changed files
+8 -4
+1
main.go
··· 41 41 } 42 42 43 43 backupPDS(ctx, minioClient, bucketName) 44 + backupTangledKnot(ctx, minioClient, bucketName) 44 45 } 45 46 46 47 func createMinioClient() (*minio.Client, error) {
+7 -4
tangled_knot.go
··· 14 14 ) 15 15 16 16 func backupTangledKnot(ctx context.Context, minioClient *minio.Client, bucketName string) { 17 - if os.Getenv("BACKUP_TANGLED_KNOT") != "true" { 18 - return 19 - } 20 - 21 17 backupKnotDB(ctx, minioClient, bucketName) 18 + backupKnotRepos(ctx, minioClient, bucketName) 22 19 } 23 20 24 21 func backupKnotDB(ctx context.Context, minioClient *minio.Client, bucketName string) { 25 22 dir := os.Getenv("TANGLED_KNOT_DATABASE_DIRECTORY") 23 + if dir == "" { 24 + slog.Info("TANGLED_KNOT_DATABASE_DIRECTORY env not set - skipping knot DB backup") 25 + } 26 26 27 27 pipeReader, pipeWriter := io.Pipe() 28 28 defer pipeReader.Close() ··· 38 38 39 39 func backupKnotRepos(ctx context.Context, minioClient *minio.Client, bucketName string) { 40 40 dir := os.Getenv("TANGLED_KNOT_REPOSITORY_DIRECTORY") 41 + if dir == "" { 42 + slog.Info("TANGLED_KNOT_REPOSITORY_DIRECTORY env not set - skipping knot repo backup") 43 + } 41 44 42 45 pipeReader, pipeWriter := io.Pipe() 43 46 defer pipeReader.Close()