script

// Send to Logseq Journal - Drafts Action Script
// Version: 1.2.2
//
// This script appends draft content to today's journal in Logseq.
// First line becomes the parent block, remaining lines become children.
//
// Requirements:
// - Logseq running with HTTP API server enabled
// - API token configured in Logseq settings
// - "Allow asynchronous execution" enabled in Drafts action step
//
// Note on banners: only one final app.displayXxxMessage() is ever fired.
// Earlier versions used an intermediate displayInfoMessage() progress
// banner; in Drafts 52.0.1 / macOS 26.3.1 rapid-fire UserNotification
// scheduling raced with ActionKit teardown and crashed Drafts ("BUG IN
// CLIENT OF LIBDISPATCH: dispatch_sync called on queue already owned by
// current thread" on com.agiletortoise.Drafts5.scriptEngine). Progress
// now goes to console.log only.
//
// Note on batching: all children are inserted in a single
// logseq.Editor.insertBatchBlock call (total = 2 HTTP round-trips,
// regardless of child count). Previously did 1 + N sequential round-trips,
// which often tripped Drafts' async-script timeout warning on larger
// drafts.

// ============================================
// Configuration
// ============================================

const LOGSEQ_API_URL = "http://127.0.0.1:12315/api";

// ============================================
// Helper Functions
// ============================================

/**
 * Strip markdown header marks from text (e.g., "## Title" -> "Title")
 */
function stripHeaderMarks(text) {
    return text.replace(/^#+\s*/, "");
}

/**
 * Strip list marker prefixes from text (e.g., "- item" -> "item")
 * Handles: -, *, + (but NOT numbered lists, which are preserved)
 */
function stripListPrefix(text) {
    // Strip leading whitespace, then bullet prefix (-, *, +) followed by space
    return text.replace(/^\s*[\-\*\+]\s+/, "");
}

/**
 * Format date for Logseq journal page name
 * Logseq default format: "Jan 17th, 2026"
 */
function formatLogseqJournalDate(date) {
    const months = ["Jan", "Feb", "Mar", "Apr", "May", "Jun",
                    "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"];
    const day = date.getDate();
    const suffix = (day === 1 || day === 21 || day === 31) ? "st" :
                   (day === 2 || day === 22) ? "nd" :
                   (day === 3 || day === 23) ? "rd" : "th";
    return months[date.getMonth()] + " " + day + suffix + ", " + date.getFullYear();
}

/**
 * Make a request to Logseq HTTP API
 */
function logseqRequest(method, args, token) {
    var http = HTTP.create();

    try {
        var response = http.request({
            "url": LOGSEQ_API_URL,
            "method": "POST",
            "encoding": "json",
            "headers": {
                "Authorization": "Bearer " + token,
                "Content-Type": "application/json"
            },
            "data": {
                "method": method,
                "args": args
            }
        });
        return response;
    } catch (e) {
        return {
            success: false,
            statusCode: 0,
            responseText: ""
        };
    }
}

/**
 * Parse response from Logseq API
 */
function parseResponse(response) {
    if (!response.success) {
        return {
            success: false,
            error: "HTTP request failed with status " + response.statusCode
        };
    }

    try {
        var data = JSON.parse(response.responseText);
        if (data.error) {
            return {
                success: false,
                error: data.error.message || JSON.stringify(data.error)
            };
        }
        return {
            success: true,
            result: data
        };
    } catch (e) {
        return {
            success: false,
            error: "Failed to parse response: " + e.message
        };
    }
}

// ============================================
// Main Script
// ============================================

function main() {
    // 1. Get API token from secure credential storage
    var credential = Credential.create("Logseq API", "Logseq HTTP API authentication token");
    credential.addPasswordField("token", "API Token");

    if (!credential.authorize()) {
        app.displayErrorMessage("Authorization cancelled");
        context.fail();
        return;
    }

    var token = credential.getValue("token");

    if (!token || token.trim() === "") {
        app.displayErrorMessage("No API token provided");
        context.fail();
        return;
    }

    // 2. Parse draft content
    var lines = draft.content.split("\n").filter(function(line) {
        return line.trim() !== "";
    });

    if (lines.length === 0) {
        app.displayErrorMessage("Draft is empty");
        context.fail();
        return;
    }

    var parentContent = stripHeaderMarks(lines[0]);
    var childLines = lines.slice(1).map(function(line) {
        return stripListPrefix(line);
    });

    // 3. Get today's journal page name
    var today = new Date();
    var journalPage = formatLogseqJournalDate(today);

    // 4. Append parent block to journal page.
    // No app.displayInfoMessage() here — see header note on the ActionKit
    // dispatch_sync crash; intermediate banners are intentionally suppressed.
    console.log("appendBlockInPage: " + journalPage);

    var appendResponse = logseqRequest(
        "logseq.Editor.appendBlockInPage",
        [journalPage, parentContent],
        token
    );

    var appendResult = parseResponse(appendResponse);

    if (!appendResult.success) {
        app.displayErrorMessage("Failed to append block: " + appendResult.error);
        context.fail();
        return;
    }

    // 5. Insert all children in ONE batch call under the parent block.
    // insertBatchBlock with sibling:false makes the array items children
    // of parentUUID. Single round-trip regardless of child count.
    var parentBlock = appendResult.result;

    if (childLines.length > 0 && parentBlock && parentBlock.uuid) {
        var parentUUID = parentBlock.uuid;
        var childBlocks = childLines.map(function(line) {
            return { "content": line };
        });

        console.log("insertBatchBlock under parent UUID: " + parentUUID + " (children: " + childLines.length + ")");

        var batchResponse = logseqRequest(
            "logseq.Editor.insertBatchBlock",
            [parentUUID, childBlocks, {"sibling": false}],
            token
        );

        var batchResult = parseResponse(batchResponse);

        if (!batchResult.success) {
            // Single final banner (see header note on the ActionKit dispatch_sync
            // crash; never fire two banners back-to-back). Parent already landed.
            app.displayWarningMessage("Sent to " + journalPage + " — children failed: " + batchResult.error);
            return;
        }
    }

    // 6. Success!
    var childCount = childLines.length;
    var message = "Sent to " + journalPage;
    if (childCount > 0) {
        message += " (" + childCount + " child block" + (childCount > 1 ? "s" : "") + ")";
    }
    app.displaySuccessMessage(message);
}

main();
script.complete();