+14 -10

src/plonk.gleam

··· 249 249 html.main([attr.class("container")], [ 250 250 html.section([attr.class("content")], [ 251 251 header(option.is_some(model.handle)), 252 252 - case model.show_spinner { 253 253 - True -> loading_spinner() 254 254 - False -> element.none() 255 255 - }, 256 256 - // TODO: move to own page + login button in header 257 257 - case model.show_login { 258 258 - True -> login_container(model.login_form, model.login_busy) 259 259 - False -> element.none() 260 260 - }, 261 252 case model.route { 262 253 HomePage(home_model) -> 263 254 home.view(home_model) |> element.map(HomePageMsg) 264 255 ImageViewPage(image_view_model) -> 265 256 image_view.view(image_view_model) |> element.map(ImageViewPageMsg) 266 257 UploadPage(upload_model) -> 267 267 - upload.view(upload_model) |> element.map(UploadPageMsg) 258 258 + case model.show_spinner { 259 259 + True -> loading_spinner() 260 260 + False -> 261 261 + case model.agent { 262 262 + None -> html.text("Error: not logged in") 263 263 + Some(_) -> 264 264 + upload.view(upload_model) |> element.map(UploadPageMsg) 265 265 + } 266 266 + } 267 267 + }, 268 268 + // TODO: move to own page + login button in header 269 269 + case model.show_login { 270 270 + True -> login_container(model.login_form, model.login_busy) 271 271 + False -> element.none() 268 272 }, 269 273 ]), 270 274 ])

-29

src/plonk/atp.ffi.mjs

··· 125 125 /** 126 126 * 127 127 * @param {Agent} agent 128 128 - * @param {BlobRef} blobRef 129 129 - * @param {String} title 130 130 - * @returns 131 131 - */ 132 132 - export async function createImageRecord(agent, blobRef, title) { 133 133 - let res; 134 134 - try { 135 135 - res = await agent.com.atproto.repo.createRecord({ 136 136 - repo: agent.did, 137 137 - collection: "top.plonk.image", 138 138 - record: { 139 139 - $type: "top.plonk.image", 140 140 - title: title, 141 141 - content: blobRef, 142 142 - createdAt: new Date().toISOString(), 143 143 - }, 144 144 - }); 145 145 - if (!res.success) { 146 146 - return Result$Error(JSON.stringify(res)); 147 147 - } 148 148 - return Result$Ok(res.data); 149 149 - } catch (err) { 150 150 - return Result$Error(`${err}`); 151 151 - } 152 152 - } 153 153 - 154 154 - /** 155 155 - * 156 156 - * @param {Agent} agent 157 128 * @param {ComAtprotoRepoUploadBlob.InputSchema} blob 158 129 * @param {ComAtprotoRepoUploadBlob.CallOptions?} options 159 130 * @returns {Promise<Result<ComAtprotoRepoUploadBlob.OutputSchema, null>>}

-9

src/plonk/atp.gleam

··· 73 73 74 74 @external(javascript, "./atp.ffi.mjs", "blobRef") 75 75 pub fn get_blob_ref(output_schema _: BlobOutputSchema) -> BlobRef 76 76 - 77 77 - pub type CreateRecordOutputSchema 78 78 - 79 79 - @external(javascript, "./atp.ffi.mjs", "createImageRecord") 80 80 - pub fn create_image_record( 81 81 - agent _: Agent, 82 82 - blob_ref _: BlobRef, 83 83 - title _: String, 84 84 - ) -> promise.Promise(Result(CreateRecordOutputSchema, String))

+3 -2

src/plonk/pages/upload.gleam

··· 8 8 import plonk/atp 9 9 import plonk/file 10 10 import plonk/forms 11 11 + import plonk/record/image 11 12 12 13 pub type Model { 13 14 Model(upload_is_busy: Bool, files: List(file.File)) ··· 16 17 pub type Msg { 17 18 UserSubmittedUploadForm(formdata: List(#(String, forms.FormDataType))) 18 19 ClientUploadedBlob(result: Result(atp.BlobOutputSchema, Nil)) 19 19 - ClientCreatedRecord(result: Result(atp.CreateRecordOutputSchema, String)) 20 20 + ClientCreatedRecord(result: Result(image.OutputSchema, String)) 20 21 } 21 22 22 23 pub fn init(_flags: Nil) -> #(Model, effect.Effect(Msg)) { ··· 64 65 ClientUploadedBlob(result: Ok(output_schema)) -> #( 65 66 model, 66 67 effect.from(fn(dispatch) { 67 67 - atp.create_image_record(agent, atp.get_blob_ref(output_schema:), "") 68 68 + image.create_record(agent, "", "", atp.get_blob_ref(output_schema:)) 68 69 |> promise.map(ClientCreatedRecord) 69 70 |> promise.tap(dispatch) 70 71 Nil

+48

src/plonk/record/image.ffi.mjs

··· 1 1 + import { ComAtprotoRepoCreateRecord } from "@atproto/api"; 2 2 + 3 3 + /** 4 4 + * 5 5 + * @param {Agent} agent 6 6 + * @param {String} title 7 7 + * @param {String} description 8 8 + * @param {BlobRef} blobRef 9 9 + * @returns {Promise<Result<ComAtprotoRepoCreateRecord.OutputSchema, String>>} 10 10 + */ 11 11 + export async function createRecord(agent, title, description, blobRef) { 12 12 + let res; 13 13 + try { 14 14 + res = await agent.com.atproto.repo.createRecord({ 15 15 + repo: agent.did, 16 16 + collection: "top.plonk.image", 17 17 + record: { 18 18 + $type: "top.plonk.image", 19 19 + title: title, 20 20 + description: description, 21 21 + content: blobRef, 22 22 + createdAt: new Date().toISOString(), 23 23 + }, 24 24 + }); 25 25 + if (!res.success) { 26 26 + return Result$Error(JSON.stringify(res)); 27 27 + } 28 28 + return Result$Ok(res.data); 29 29 + } catch (err) { 30 30 + return Result$Error(`${err}`); 31 31 + } 32 32 + } 33 33 + 34 34 + /** 35 35 + * @param {ComAtprotoRepoCreateRecord.OutputSchema} output 36 36 + * @returns {String} uri 37 37 + */ 38 38 + export function getUri(output) { 39 39 + return output.uri; 40 40 + } 41 41 + 42 42 + /** 43 43 + * @param {ComAtprotoRepoCreateRecord.OutputSchema} output 44 44 + * @returns {String} cid 45 45 + */ 46 46 + export function getCid(output) { 47 47 + return output.cid; 48 48 + }

+39

src/plonk/record/image.gleam

··· 1 1 + import gleam/javascript/promise 2 2 + import gleam/result 3 3 + import plonk/atp 4 4 + 5 5 + pub type OutputSchema { 6 6 + OutputSchema(uri: String, cid: String) 7 7 + } 8 8 + 9 9 + type CreateRecordOutputSchema 10 10 + 11 11 + pub fn create_record( 12 12 + agent: atp.Agent, 13 13 + title: String, 14 14 + description: String, 15 15 + content: atp.BlobRef, 16 16 + ) -> promise.Promise(Result(OutputSchema, String)) { 17 17 + do_create_record(agent, title, description, content) 18 18 + |> promise.map(fn(r) { 19 19 + result.map(r, fn(output_schema) { 20 20 + let uri = get_uri(output_schema) 21 21 + let cid = get_cid(output_schema) 22 22 + OutputSchema(uri:, cid:) 23 23 + }) 24 24 + }) 25 25 + } 26 26 + 27 27 + @external(javascript, "./image.ffi.mjs", "createRecord") 28 28 + fn do_create_record( 29 29 + agent _: atp.Agent, 30 30 + title _: String, 31 31 + description _: String, 32 32 + content _: atp.BlobRef, 33 33 + ) -> promise.Promise(Result(CreateRecordOutputSchema, String)) 34 34 + 35 35 + @external(javascript, "./image.ffi.mjs", "getUri") 36 36 + fn get_uri(output: CreateRecordOutputSchema) -> String 37 37 + 38 38 + @external(javascript, "./image.ffi.mjs", "getCid") 39 39 + fn get_cid(output: CreateRecordOutputSchema) -> String