Something went wrong. Try again.
Mirror of https://github.com/improsocial/improAn extensible Bluesky client for web
Something went wrong. Try again.
JavaScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128import "/js/components/post-composer.js";import { createEmbedFromPost } from "/js/dataHelpers.js";import { showToast } from "/js/toasts.js";import { html } from "/js/lib/lit-html.js";import { linkToPostFromUri } from "/js/navigation.js";import { hapticsImpactLight } from "/js/haptics.js";
export class PostComposerService { constructor(dataLayer, identityResolver, pluginService, { draftsEnabled }) { this.dataLayer = dataLayer; this.identityResolver = identityResolver; this.pluginService = pluginService; this.currentPostComposer = null; this.draftsEnabled = draftsEnabled; }
async composePost({ currentUser, replyTo = null, replyRoot = null, quotedPost = null, }) { if (!currentUser) { console.warn("No current user"); return; } if (this.currentPostComposer !== null) { console.warn("Post composer already open"); return; } hapticsImpactLight(); return new Promise((resolve, reject) => { this.currentPostComposer = document.createElement("post-composer"); this.currentPostComposer.dataLayer = this.dataLayer; this.currentPostComposer.identityResolver = this.identityResolver; this.currentPostComposer.pluginService = this.pluginService; this.currentPostComposer.replyTo = replyTo; this.currentPostComposer.replyRoot = replyRoot; this.currentPostComposer.quotedRecord = quotedPost ? createEmbedFromPost(quotedPost) : null; this.currentPostComposer.currentUser = currentUser; this.currentPostComposer.draftsEnabled = this.draftsEnabled; this.currentPostComposer.addEventListener("send-post", async (e) => { const { posts, replyTo: sendReplyTo, replyRoot: sendReplyRoot, threadgateAllow, postgateEmbeddingRules, draft, position, successCallback, errorCallback, } = e.detail; try { const res = await this.dataLayer.mutations.createThread({ posts, replyTo: sendReplyTo, replyRoot: sendReplyRoot, threadgateAllow, postgateEmbeddingRules, }); this.pluginService.broadcastEvent("post-created", { uri: res.uris[0], isReply: Boolean(sendReplyTo), position, }); let toastMessage = "Your post was sent"; if (posts.length > 1) { toastMessage = "Your posts were sent"; } else if (sendReplyTo) { toastMessage = "Your reply was sent"; } showToast( html`<div class="toast-with-link"> ${toastMessage}<a href="${linkToPostFromUri(res.uris[0])}" >View</a > </div>`, { style: "success" }, ); // Publishing a saved/restored draft consumes it if (draft) { this.dataLayer.mutations.deleteDraft(draft).catch((error) => { console.error("Failed to clean up published draft", error); }); } successCallback(res); resolve(res); } catch (error) { console.error(error); errorCallback(error); reject(error); } }); // Destroy on close this.currentPostComposer.addEventListener("post-composer-closed", () => { if (this.currentPostComposer) { this.currentPostComposer.remove(); this.currentPostComposer = null; } }); document.body.appendChild(this.currentPostComposer); // Open (and focus) synchronously: iOS Safari only honors programmatic // focus while still inside the user-gesture handler, so the composer // can't wait on plugin init before opening this.currentPostComposer.open(); const composer = this.currentPostComposer; this.pluginService .getPostComposerInit({ kind: replyTo ? "reply" : quotedPost ? "quote" : "post", replyTo, replyRoot, quotedPost, }) .then((composerInit) => { if (composerInit && this.currentPostComposer === composer) { composer.applyComposerInit(composerInit); } }) .catch((error) => { console.error("Failed to get post composer init", error); }); }); }}