aerc - mirror of ~rjarry's aerc fork - a pretty good email client

	Commit message (Expand)	Author	Age	Files	Lines
*	s/aerc2/aerc/g	Drew DeVault	2019-05-17	6	-6/+6
*	Copy sent emails to the Sent folder	Drew DeVault	2019-05-15	2	-0/+31
*	Implement :copy (aka :cp)	Drew DeVault	2019-05-14	2	-0/+18
*	Handle external message deletions	Drew DeVault	2019-05-13	1	-0/+7
*	Handle incoming emails gracefully	Drew DeVault	2019-05-13	2	-3/+23
*	worker/imap: use the IMAP connection from a single goroutine	Simon Ser	2019-04-29	3	-86/+77
*	Make message viewer real, part two	Drew DeVault	2019-03-31	1	-11/+14
*	Rename FetchMessageBodies to FetchFullMessages	Drew DeVault	2019-03-31	2	-12/+12
*	Make the message viewer real, part one	Drew DeVault	2019-03-31	2	-6/+28
*	Don't parse mail in worker; send a reader instead	Drew DeVault	2019-03-31	1	-10/+2
*	Pull BodyStructure up from IMAP worker	Drew DeVault	2019-03-31	1	-4/+6
*	Add body fetching support code	Drew DeVault	2019-03-29	2	-15/+48
*	Implement :delete-message	Drew DeVault	2019-03-20	4	-1/+50
*	Display message subjects in message list	Drew DeVault	2019-03-14	2	-0/+48
*	Implement message store side of message fetching	Drew DeVault	2019-03-14	1	-7/+2
*	Fetch valid UIDs from server after opening dir	Drew DeVault	2019-03-10	2	-3/+43
*	Add name to DirectoryInfo messages	Drew DeVault	2019-01-13	1	-1/+2
*	Issue IMAP SELECT command	Drew DeVault	2019-01-13	2	-1/+39
*	Tidy up list.go	Drew DeVault	2018-02-02	1	-22/+15
*	Refactoring; consume listing response	Drew DeVault	2018-02-01	2	-25/+26
*	Implement (most of) mailbox listing	Drew DeVault	2018-02-01	2	-3/+40
*	Reduce boilerplate in worker/UI	Drew DeVault	2018-02-01	1	-34/+15
*	Add certificate approval flow	Drew DeVault	2018-01-31	1	-26/+55
*	Improve logging	Drew DeVault	2018-01-31	1	-5/+23
*	Connect to IMAP server, login and idle	emersion	2018-01-14	1	-11/+111
*	Move worker into account tab	Drew DeVault	2018-01-11	1	-7/+2
*	Renderer scaffolding	Drew DeVault	2018-01-10	1	-2/+0
*	Misc idiomatic fixes	emersion	2018-01-10	1	-5/+5
*	Sleep main and worker loops on idle	Drew DeVault	2018-01-10	1	-1/+2
*	Parse account configuration	Drew DeVault	2018-01-09	1	-3/+3
*	Initial pass on worker/UI message passing	Drew DeVault	2018-01-09	1	-0/+58

import std/tables import types/opt type PromiseState* = enum PROMISE_PENDING, PROMISE_FULFILLED, PROMISE_REJECTED EmptyPromise* = ref object of RootObj cb: (proc()) next: EmptyPromise opaque: pointer state*: PromiseState Promise*[T] = ref object of EmptyPromise res: T get: GetValueProc[T] GetValueProc[T] = (proc(opaque: pointer, res: var T)) PromiseMap* = object tab: Table[int, EmptyPromise] opaque*: pointer proc newPromise*[T](): Promise[T] = return Promise[T]() proc newPromiseMap*(opaque: pointer): PromiseMap = return PromiseMap( opaque: opaque ) proc addPromise*[T](map: var PromiseMap, id: int, get: GetValueProc[T]): Promise[T] = let promise = Promise[T](get: get, opaque: map.opaque) map.tab[id] = promise return promise proc addEmptyPromise*(map: var PromiseMap, id: int): EmptyPromise = let promise = EmptyPromise(opaque: map.opaque) map.tab[id] = promise return promise proc resolve*(promise: EmptyPromise) = var promise = promise while true: if promise.cb != nil: promise.cb() promise.cb = nil promise.state = PROMISE_FULFILLED promise = promise.next if promise == nil: break promise.next = nil proc resolve*[T](promise: Promise[T], res: T) = if promise.cb != nil: if promise.get != nil: promise.get(promise.opaque, promise.res) promise.get = nil promise.res = res promise.resolve() proc resolve*(map: var PromiseMap, promiseid: int) = var promise: EmptyPromise if map.tab.pop(promiseid, promise): promise.resolve() proc newResolvedPromise*(): EmptyPromise = let res = EmptyPromise() res.resolve() return res func empty*(map: PromiseMap): bool = map.tab.len == 0 proc then*(promise: EmptyPromise, cb: (proc())): EmptyPromise {.discardable.} = promise.cb = cb promise.next = EmptyPromise() if promise.state == PROMISE_FULFILLED: promise.resolve() return promise.next proc then*(promise: EmptyPromise, cb: (proc(): EmptyPromise)): EmptyPromise {.discardable.} = let next = EmptyPromise() promise.then(proc() = var p2 = cb() if p2 != nil: p2.then(proc() = next.resolve()) else: next.resolve()) return next proc then*[T](promise: Promise[T], cb: (proc(x: T))): EmptyPromise {.discardable.} = return promise.then(proc() = if promise.get != nil: promise.get(promise.opaque, promise.res) promise.get = nil cb(promise.res)) proc then*[T](promise: EmptyPromise, cb: (proc(): Promise[T])): Promise[T] {.discardable.} = let next = Promise[T]() promise.then(proc() = var p2 = cb() if p2 != nil: p2.then(proc(x: T) = next.res = x next.resolve()) else: next.resolve()) return next proc then*[T](promise: Promise[T], cb: (proc(x: T): EmptyPromise)): EmptyPromise {.discardable.} = let next = EmptyPromise() promise.then(proc(x: T) = let p2 = cb(x) if p2 != nil: p2.then(proc() = next.resolve()) else: next.resolve()) return next proc then*[T, U](promise: Promise[T], cb: (proc(x: T): U)): Promise[U] {.discardable.} = let next = Promise[U]() promise.then(proc(x: T) = next.res = cb(x) next.resolve()) return next proc then*[T, U](promise: Promise[T], cb: (proc(x: T): Promise[U])): Promise[U] {.discardable.} = let next = Promise[U]() promise.then(proc(x: T) = let p2 = cb(x) if p2 != nil: p2.then(proc(y: U) = next.res = y next.resolve()) else: next.resolve()) return next proc then*[T, U](promise: Promise[T], cb: (proc(x: T): Opt[Promise[U]])): Promise[Opt[U]] {.discardable.} = let next = Promise[Opt[U]]() promise.then(proc(x: T) = let p2 = cb(x) if p2.isOk: p2.get.then(proc(y: U) = next.res = opt(y) next.resolve()) else: next.resolve()) return next proc all*(promises: seq[EmptyPromise]): EmptyPromise = let res = EmptyPromise() var i = 0 for promise in promises: promise.then(proc() = inc i if i == promises.len: res.resolve()) if promises.len == 0: res.resolve() return res