From 43fbddf016f94f4ba006d82c9a67dca61b5852a1 Mon Sep 17 00:00:00 2001
From: Gab <24553253+gabrix73@users.noreply.github.com>
Date: Fri, 14 Aug 2026 20:39:22 +0200
Subject: Complete Nym and YAMN transport integration

---
 katzenpost/cmd/yamn-dispatcher/main.go | 115 ---------------------------------
 1 file changed, 115 deletions(-)
 delete mode 100644 katzenpost/cmd/yamn-dispatcher/main.go

(limited to 'katzenpost/cmd/yamn-dispatcher/main.go')

diff --git a/katzenpost/cmd/yamn-dispatcher/main.go b/katzenpost/cmd/yamn-dispatcher/main.go
deleted file mode 100644
index 8f10034..0000000
--- a/katzenpost/cmd/yamn-dispatcher/main.go
+++ /dev/null
@@ -1,115 +0,0 @@
-package main
-
-import (
-	"errors"
-	"flag"
-	"fmt"
-	"os"
-	"path/filepath"
-	"strings"
-	"time"
-
-	"git.virebent.art/virebent/yamnweb/katzenpost/dispatcher"
-	"github.com/katzenpost/katzenpost/core/log"
-	"github.com/katzenpost/katzenpost/server/cborplugin"
-)
-
-const capability = "yamn-dispatch-v1"
-
-type plugin struct {
-	write          func(cborplugin.Command)
-	reassembler    *dispatcher.Reassembler
-	allowedDomains map[string]struct{}
-}
-
-func (p *plugin) OnCommand(command cborplugin.Command) error {
-	request, ok := command.(*cborplugin.Request)
-	if !ok {
-		return errors.New("unexpected plugin command")
-	}
-	frame, err := dispatcher.DecodeFrame(request.Payload)
-	if err != nil {
-		return err
-	}
-	encoded, complete, err := p.reassembler.Add(frame)
-	if err != nil || !complete {
-		return err
-	}
-	envelope, err := dispatcher.DecodeEnvelope(encoded)
-	if err != nil {
-		return err
-	}
-	if err := envelope.Validate(p.allowedDomains); err != nil {
-		return err
-	}
-	// PoC sink: successful validation intentionally has no external side effect.
-	return nil
-}
-
-func (p *plugin) RegisterConsumer(server *cborplugin.Server) {
-	p.write = server.Write
-}
-
-func parseDomains(value string) (map[string]struct{}, error) {
-	domains := make(map[string]struct{})
-	for _, domain := range strings.Split(value, ",") {
-		domain = strings.ToLower(strings.TrimSpace(domain))
-		if domain == "" || strings.ContainsAny(domain, "@/\\: ") {
-			return nil, errors.New("invalid allowed domain")
-		}
-		domains[domain] = struct{}{}
-	}
-	if len(domains) == 0 {
-		return nil, errors.New("at least one allowed domain is required")
-	}
-	return domains, nil
-}
-
-func run() error {
-	var allowed string
-	var logDir string
-	var logLevel string
-	flag.StringVar(&allowed, "allowed-domains", "remailer.example", "comma-separated entry remailer domains")
-	flag.StringVar(&logDir, "log-dir", "/tmp", "operational log directory")
-	flag.StringVar(&logLevel, "log-level", "NOTICE", "Katzenpost log level")
-	flag.Parse()
-
-	domains, err := parseDomains(allowed)
-	if err != nil {
-		return err
-	}
-	info, err := os.Stat(logDir)
-	if err != nil || !info.IsDir() {
-		return errors.New("log directory is unavailable")
-	}
-	backend, err := log.New(filepath.Join(logDir, "yamn-dispatch.log"), logLevel, false)
-	if err != nil {
-		return fmt.Errorf("initialize logging: %w", err)
-	}
-	logger := backend.GetLogger("yamn_dispatch")
-
-	socketDir, err := os.MkdirTemp("", "yamn-dispatch-")
-	if err != nil {
-		return fmt.Errorf("create socket directory: %w", err)
-	}
-	defer os.RemoveAll(socketDir)
-	socketPath := filepath.Join(socketDir, "plugin.sock")
-	service := &plugin{
-		reassembler:    dispatcher.NewReassembler(5 * time.Minute),
-		allowedDomains: domains,
-	}
-	server := cborplugin.NewServer(logger, socketPath, new(cborplugin.RequestFactory), service)
-	if _, err := fmt.Fprintln(os.Stdout, socketPath); err != nil {
-		return fmt.Errorf("publish socket path: %w", err)
-	}
-	server.Accept()
-	server.Wait()
-	return nil
-}
-
-func main() {
-	if err := run(); err != nil {
-		fmt.Fprintln(os.Stderr, "yamn-dispatcher failed")
-		os.Exit(1)
-	}
-}
-- 
cgit v1.2.3