Ben Gotow
76d873c2b2
Reintroduce concept of provider
, start work on Gmail
2016-06-27 10:43:53 -07:00
Halla Moore
ab4c8cf32c
Add id query to threads route
2016-06-27 10:35:34 -07:00
Juan Tejada
1fe7fdf4b1
More sync error handling WIP
2016-06-27 10:27:38 -07:00
Halla Moore
621f8b5c2b
Add starred query to threads route
2016-06-27 10:15:05 -07:00
Juan Tejada
63b929e59b
Fix missing promise based error handling in sync-worker
2016-06-26 09:52:03 -07:00
Juan Tejada
dd350a5081
Update IMAPConnection api + error handling fixes + misc
...
- `IMAPConnection::openBox` now returns a Promise that resolves to an
IMAPBox, and IMAPBox contains all of the `fetch` operations. This makes
the dependency between fetch operations and the currently open mailbox
explicit rather than implicit and by forcing the operations to be called on
a box instance and hopefully prevent errors. It will also throw an error
if the constraint is no longer satisfied.
- `fetch` operations now return an observable stream of messages (or Promise for single value),
while preserving the same logic of the original implementation. You can use `.toPromise()` on
the observable to get a Promise that resolves when the observable stream has
completely drained.
- Fixes error handling in a few places and renames some variables
2016-06-26 01:57:33 -07:00
Juan Tejada
63f48ae817
Adds hapi-boom for easy error responses
2016-06-26 01:44:39 -07:00
Juan Tejada
1336dea0d4
Fix auth response + log errors
2016-06-25 22:19:05 -07:00
Juan Tejada
caaef8d5b5
Add /messages/<id> enpoint + support for raw message/rfc822
...
- When message/rfc822 is requested, fetch ray message from IMAP
connection
2016-06-25 11:25:34 -07:00
Ben Gotow
69e87cbf49
Gmail auth at http://localhost:5100/auth/gmail
2016-06-24 16:46:41 -07:00
Halla Moore
bc5a4ecf3c
Add unread query to threads route
2016-06-24 16:14:04 -07:00
Halla Moore
18ad15937f
Change uppercase instance of Joi to lowercase
2016-06-24 14:07:10 -07:00
Juan Tejada
7e2c487034
Update README with auth instructions
2016-06-24 11:57:24 -07:00
Juan Tejada
8f945888e4
Add missing test fixtures and fix path for reading them
2016-06-24 10:39:30 -07:00
Juan Tejada
ee2dc6c3f6
Expect true to be true
2016-06-24 10:36:57 -07:00
Juan Tejada
0ac3c8c313
Add jasmine for message-processor
2016-06-24 10:35:34 -07:00
Ben Gotow
b67a3ae3e4
Launch dashboard when in dev mode, publish change on acct creation
2016-06-23 18:17:04 -07:00
Ben Gotow
f678045c4f
sync db <=> redis with sequelize hooks
2016-06-23 16:28:51 -07:00
Ben Gotow
eac019f536
Rather than changing policies, just set expiring redis key to track activity
2016-06-23 16:28:48 -07:00
Ben Gotow
09bb7874f8
Dashboard with a sweet background. Also realtime assignment / policy view.
2016-06-23 15:52:53 -07:00
Evan Morikawa
3f5cac4342
Adding in syncback message actions
2016-06-23 16:47:07 -06:00
Jackie Luo
b6f57f3ce8
Add threading algorithm
2016-06-23 15:44:03 -07:00
Jackie Luo
f9fe836899
Fix syntax error
2016-06-23 15:21:54 -07:00
Jackie Luo
5cc4841ac6
Add check for Gmail thread ID
2016-06-23 15:19:20 -07:00
Evan Morikawa
6ad9cdd322
Fixing broken processors
2016-06-23 14:15:30 -06:00
Evan Morikawa
8160acc81e
Add imap dependency to package.json
2016-06-23 13:18:33 -06:00
Evan Morikawa
1460a0ae9f
Rename Refresh to Sync
2016-06-23 13:16:15 -06:00
Ben Gotow
8e692982bb
Remove concept of self-limiting workers, will use cloudwatch metrics collection to scale fleet instead of queue length
2016-06-23 12:02:57 -07:00
Ben Gotow
f7c647f7ba
Return syncs to unclaimed queue after CLAIM_DURATION, just because it's healthy
2016-06-23 11:45:33 -07:00
Ben Gotow
c2e9093b42
Escalate sync policy based on number of stream connections
2016-06-23 11:45:33 -07:00
Jackie Luo
ae54192ed6
Update threading and fix typo
2016-06-23 10:35:47 -07:00
Juan Tejada
a917022505
Update order of threading processor
2016-06-23 10:26:41 -07:00
Ben Gotow
ad1683c9a5
Fix reference to __base
2016-06-23 10:11:07 -07:00
Ben Gotow
12d9db8dd9
Redis coordination of sync processes / assignment
2016-06-23 00:49:26 -07:00
Ben Gotow
2e9bfa68b5
Refactor DeltaStreamQueue (connection per subscription)
2016-06-23 00:49:26 -07:00
Jackie Luo
cb95574378
Fix associations
2016-06-22 17:34:29 -07:00
Jackie Luo
e64c2ae4c0
Add basic threading
2016-06-22 17:34:29 -07:00
Ben Gotow
f5f435236f
/auth + remove hardcoded stub in favor of curl request
2016-06-22 17:19:48 -07:00
Evan Morikawa
d5d019f9d9
Plain npm install
2016-06-22 14:53:23 -07:00
Evan Morikawa
71167328dd
Update readme
2016-06-22 14:49:36 -07:00
Evan Morikawa
06393dd07c
Move categories & messages to new monorepo structure
2016-06-22 14:44:09 -07:00
Ben Gotow
95fbb64d17
Add /messages, /folders, /account
2016-06-22 14:42:08 -07:00
Evan Morikawa
18f2925b43
Convert to monorepo
2016-06-22 14:41:32 -07:00
Evan Morikawa
2c5da59d74
Properly pluck out transactionModel
2016-06-22 13:57:51 -07:00
Evan Morikawa
02f0788232
Improving observable based delta stream
2016-06-22 13:35:55 -07:00
Evan Morikawa
54599a21c0
Ignore storage folder
2016-06-22 12:19:17 -07:00
Evan Morikawa
135f16f8d6
Add initial observable based delta stream endpoint
2016-06-22 12:16:41 -07:00
Juan Tejada
5bf63f8ea6
Fix message processor pipeline initialization
...
- Was not actually returning an array of functions from
`processors/index.js`
2016-06-22 11:57:24 -07:00
Juan Tejada
8172cad622
Fix syntax error
2016-06-22 11:01:51 -07:00
Juan Tejada
c3ed7cbdef
Adds message parsing module + other updates
...
- Adds an order for the message processing pipeline to ensure that
parsing occurs first
- Adds JSONARRAYType
- Other misc updates
2016-06-22 11:00:35 -07:00