#!/usr/bin/env python3

"""Enqueue a signed task to the other node's inbox.

Usage:

  dispatch-send --from <node-id> --to <node-id> --request "..." [--priority normal]

"""

from __future__ import annotations

import argparse

import os

import pathlib

import sys

sys.path.insert(0, str(pathlib.Path(__file__).resolve().parent))

import dispatch_lib as d

def main() -> int:

    ap = argparse.ArgumentParser()

    ap.add_argument("--to", required=True, help="recipient node id")

    ap.add_argument("--from", dest="sender", default=os.environ.get("DISPATCH_FROM"),

                    help="sender node id (or set DISPATCH_FROM)")

    ap.add_argument("--request", required=True)

    ap.add_argument("--priority", default="normal", choices=["low", "normal", "high"])

    ap.add_argument("--callback", default="file", choices=["file", "discord", "none"])

    args = ap.parse_args()

    if not args.sender:

        print("ERR: --from required (or set DISPATCH_FROM)", file=sys.stderr)

        return 2

    if args.sender == args.to:

        print("ERR: --from and --to must differ", file=sys.stderr)

        return 2

    task = d.new_task(args.sender, args.to, args.request, args.priority, args.callback)

    path = d.enqueue(task)

    d.log_event(args.sender, "task_send", f"-> {args.to}: {args.request[:80]}", task["id"])

    print(f"{task['id']}\t{path}")

    return 0

if __name__ == "__main__":

    raise SystemExit(main())