git ssb

1
const combine = require('depject')
2
const entry = require('depject/entry')
3
const electron = require('electron')
4
const h = require('mutant/h')
5
const when = require('mutant/when')
6
const onceTrue = require('mutant/once-true')
7
const computed = require('mutant/computed')
8
const catchLinks = require('./catch-links')
9
const themes = require('../styles')
10
const nest = require('depnest')
11
const LatestUpdate = require('./latest-update')
12
const ref = require('ssb-ref')
13
const watch = require('mutant/watch')
14
const requireStyle = require('require-style')
15
const ssbUri = require('ssb-uri')
16
const pull = require('pull-stream')
17
const moment = require('moment-timezone')
18
const fullscreen = require('./fullscreen.js')
19
const appViews = require('./app/views.js')
20
const getGitHandler = require('./app/sync/external-handler/git')
21
22
const localTimezone = moment.tz.guess()
23
moment.tz.setDefault(localTimezone)
24
25
module.exports = function (config) {
26
  const sockets = combine(
27
    overrideConfig(config),
28
    addCommand('app.navigate', navigate),
29
    require('./depject'),
30
    require('patch-settings')
31
  )
32
33
  const api = entry(sockets, nest({
34
    'config.sync.load': 'first',
35
    'keys.sync.id': 'first',
36
    'sbot.obs.connection': 'first',
37
    'sbot.async.get': 'first',
38
    'blob.sync.url': 'first',
39
    'page.html.render': 'first',
40
    'app.html.search': 'first',
41
    'app.html.channels': 'first',
42
    'app.html.progressNotifier': 'first',
43
    'about.async.latestValues': 'first',
44
    'profile.sheet.edit': 'first',
45
    'profile.html.preview': 'first',
46
    'app.navigate': 'first',
47
    'app.linkPreview': 'first',
48
    'channel.obs.subscribed': 'first',
49
    'settings.obs.get': 'first',
50
    'intl.sync.i18n': 'first',
51
    'contact.obs.blocking': 'first'
52
  }))
53
54
  const i18n = api.intl.sync.i18n
55
  const language = api.settings.obs.get('patchwork.lang', '')()
56
  moment.locale(language)
57
58
  const id = api.keys.sync.id()
59
  const latestUpdate = LatestUpdate()
60
  const subscribedChannels = api.channel.obs.subscribed(id)
61
  const includeParticipating = api.settings.obs.get('patchwork.includeParticipating', false)
62
  const autoDeleteBlocked = api.settings.obs.get('patchwork.autoDeleteBlocked', false)
63
64
  // prompt to setup profile on first use
65
  onceTrue(api.sbot.obs.connection, (ssb) => {
66
    ssb.latestSequence(api.keys.sync.id(), (err, key) => {
67
      if (err) {
68
        // This may throw an error if the feed doesn't have any messages, but
69
        // that shouldn't cause any problems so this error can be ignored.
70
      }
71
72
      if (key == null) {
73
        api.profile.sheet.edit({ usePreview: false })
74
      }
75
    })
76
77
    const currentlyDeleting = {}
78
79
    watch(api.contact.obs.blocking(id), (blocking) => {
80
      if (autoDeleteBlocked() !== true) return
81
      if (blocking.length === 0) return
82
83
      if (ssb.del == null) return
84
85
      blocking
86
        .filter(feedId => feedId !== ssb.id)
87
        .forEach(feed => {
88
          pull(
89
            ssb.createUserStream({ id: feed }),
90
            pull.asyncMap((msg, cb) => {
91
              const key = msg.key
92
              if (currentlyDeleting[key] === true) {
93
                return cb(null, null) // already deleting
94
              }
95
96
              currentlyDeleting[key] = true
97
98
              ssb.del(key, (err) => {
99
                currentlyDeleting[key] = false
100
                cb(err, key)
101
              })
102
            }),
103
            pull.filter(),
104
            pull.collect((err, keys) => {
105
              if (err) {
106
                console.error(keys)
107
                throw err
108
              }
109
110
              if (keys.length > 0) {
111
                console.log(`deleted ${keys.length} messages from blocked authors`)
112
              }
113
            })
114
          )
115
        })
116
    })
117
  })
118
119
  const defaultViews = computed(includeParticipating, (includeParticipating) => {
120
    const result = [
121
      '/public', '/private', '/mentions', '/status'
122
    ]
123
124
    // allow user to choose in settings whether to show participating tab
125
    if (includeParticipating) {
126
      result.push('/participating')
127
    }
128
129
    return result
130
  })
131
132
  const views = appViews(api.page.html.render, defaultViews)
133
134
  const pendingCount = views.get('/mentions').pendingUpdates
135
136
  watch(pendingCount, count => {
137
    electron.ipcRenderer.invoke('badgeCount', count)
138
  })
139
140
  electron.ipcRenderer.on('goForward', views.goForward)
141
  electron.ipcRenderer.on('goBack', views.goBack)
142
143
  electron.ipcRenderer.on('goToSettings', () => api.app.navigate('/settings'))
144
  electron.ipcRenderer.on('goTostatus', () => api.app.navigate('/status'))
145
146
  electron.ipcRenderer.on("navigate-to", (ev, target) => {
147
    navigate(target);
148
  });
149
150
  // context menus are handled on the server. however, we need to know some
151
  // information about the element under the cursor at the time of clicking.
152
  // Sadly, electron doesn't seem to allow us to attach arbitrary information to
153
  // an event and have it be transferred to the server directly. so we need to
154
  // transfer that information "out of band" via sendSync.
155
  // Note that invoke() might cause race conditions here IFF messages can change
156
  // order in the queue between Renderer and Server, or if the IPC and document
157
  // events use different queues. I'm not sure whether that's the case, but I
158
  // haven't observed this happening yet.
159
  document.addEventListener("contextmenu", (ev) => {
160
    let element = document.elementFromPoint(ev.x, ev.y)
161
    while (element && !element.msg) {
162
      element = element.parentNode
163
    }
164
    // we only send the id, because that's cheap
165
    // if the server actually wants to copy the text, it will
166
    // ask us (see "copy-message-text" handler below)
167
    electron.ipcRenderer.invoke("context-menu-info", {
168
      msg: element?.msg || null,
169
    });
170
  })
171
172
  // for when the server process asks us to please copy a message text to
173
  // clipboard needed for context menu popups, because we want to call the
174
  // getMessage only *if* the text is actually to be copied
175
  electron.ipcRenderer.on("copy-message-text", (ev, key) => {
176
    getMessageText(key, (err, value) => {
177
      electron.clipboard.writeText(
178
        !err ? value : `Error while retrieving message ${key}:\n${err}`
179
      );
180
    });
181
  });
182
183
  document.head.appendChild(
184
    h('style', {
185
      innerHTML: computed(api.settings.obs.get('patchwork.theme', 'light'), themeName => {
186
        return themes[themeName] || themes.light
187
      })
188
    })
189
  )
190
191
  document.head.appendChild(
192
    h('style', {
193
      innerHTML: computed(api.settings.obs.get('patchwork.theme', 'light'), themeName => {
194
        const syntaxThemeOptions = {
195
          light: 'github',
196
          dark: 'monokai',
197
          dracula: 'dracula'
198
        }
199
200
        const syntaxTheme = syntaxThemeOptions[themeName] || syntaxThemeOptions.light
201
        return requireStyle(`highlight.js/styles/${syntaxTheme}.css`)
202
      })
203
    })
204
  )
205
206
  document.head.appendChild(
207
    h('style', {
208
      innerHTML: requireStyle('noto-color-emoji')
209
    })
210
  )
211
212
  document.head.appendChild(
213
    h('style', {
214
      innerHTML: computed(api.settings.obs.get('patchwork.fontSize'), size => {
215
        if (size) {
216
          return 'html, body {font-size: ' + size + ';}'
217
        }
218
      })
219
    })
220
  )
221
222
  document.head.appendChild(
223
    h('style', {
224
      innerHTML: computed(api.settings.obs.get('patchwork.fontFamily'), family => {
225
        if (family) {
226
          return 'body, input, select { font-family: ' + family + ';}'
227
        }
228
      })
229
    })
230
  )
231
232
  const container = h(`MainWindow -${process.platform}`, {
233
    classList: [when(fullscreen(), '-fullscreen')],
234
    'ev-dragover': preventDefault,
235
    'ev-drop': preventDefault,
236
    'ev-dragstart': preventDefaultUnlessImage
237
  }, [
238
    h('div.top', [
239
      h('span.history', [
240
        h('a', {
241
          'ev-click': views.goBack,
242
          classList: [when(views.canGoBack, '-active')]
243
        }),
244
        h('a', {
245
          'ev-click': views.goForward,
246
          classList: [when(views.canGoForward, '-active')]
247
        })
248
      ]),
249
      h('span.nav', [
250
        tab(i18n('Public'), '/public'),
251
        tab(i18n('Private'), '/private'),
252
        dropTab(i18n('More'))
253
      ]),
254
      h('span.appTitle', [
255
        h('span.title', i18n('Patchwork')),
256
        api.app.html.progressNotifier()
257
      ]),
258
      h('span', [api.app.html.search(api.app.navigate)]),
259
      h('span.nav', [
260
        tab(i18n('Profile'), id),
261
        computed(includeParticipating, (includeParticipating) => {
262
          if (includeParticipating) return tab(i18n('Participating'), '/participating')
263
        }),
264
        tab(i18n('Mentions'), '/mentions'),
265
      ])
266
    ]),
267
    when(latestUpdate,
268
      h('div.info', [
269
        h('a.message -update', { href: 'https://github.com/ssbc/patchwork/releases/latest' }, [
270
          h('strong', ['Patchwork ', latestUpdate, i18n(' has been released.')]), i18n(' Click here to download and view more info!'),
271
          h('a.ignore', { 'ev-click': latestUpdate.ignore }, 'X')
272
        ])
273
      ])
274
    ),
275
    views.html
276
  ])
277
278
  const previewElement = api.app.linkPreview(container, 500)
279
280
  catchLinks(container, (href, external, anchor) => {
281
    if (!href) return
282
    if (external) {
283
      electron.shell.openExternal(href)
284
    } else {
285
      api.app.navigate(href, anchor)
286
    }
287
  })
288
  return [container, previewElement]
289
290
  // scoped
291
292
  function getSubscribedChannelMenu () {
293
    const channels = Array.from(subscribedChannels()).sort(localeCompare)
294
295
    if (channels.length) {
296
      return {
297
        type: 'submenu',
298
        label: i18n('Channels'),
299
        submenu: [
300
          {
301
            type: 'normal',
302
            label: i18n('Browse Recently Active'),
303
            target: '/channels'
304
          },
305
          { type: 'separator' }
306
        ].concat(channels.map(channel => ({
307
          type: 'normal',
308
          label: `#${channel}`,
309
          target: `#${channel}`,
310
        })))
311
      }
312
    } else {
313
      return {
314
        type: 'normal',
315
        label: i18n('Browse Channels'),
316
        target: '/channels',
317
      }
318
    }
319
  }
320
321
  function buildDropdownMenuItems() {
322
    const dropTabItems = [
323
      getSubscribedChannelMenu(),
324
      {
325
        type: 'submenu',
326
        label: i18n("Participating"),
327
        submenu: [
328
          {
329
            type: "normal",
330
            label: i18n("All Threads"),
331
            target: "/participating",
332
          },
333
          {
334
            type: "normal",
335
            label: i18n("Threads Started By You"),
336
            target: "/your-posts",
337
          },
338
        ],
339
      },
340
      {
341
        type: "submenu",
342
        label: i18n("Gatherings"),
343
        submenu: [
344
          {
345
            type: "normal",
346
            label: i18n("All"),
347
            target: "/gatherings",
348
          },
349
          {
350
            type: "normal",
351
            label: i18n("Attending"),
352
            target: "/attending-gatherings",
353
          },
354
        ],
355
      },
356
      {
357
        type: "normal",
358
        label: i18n("Tags"),
359
        target: `/tags/all/${encodeURIComponent(id)}`,
360
      },
361
      {
362
        type: "normal",
363
        label: i18n("Extended Network"),
364
        target: "/all",
365
      },
366
      { type: "separator" },
367
      {
368
        type: "normal",
369
        label: i18n("Settings"),
370
        target: "/settings",
371
      },
372
      {
373
        type: "normal",
374
        label: i18n("Status"),
375
        target: "/status",
376
      },
377
    ];
378
    return dropTabItems
379
  }
380
381
  function dropTab (title) {
382
    const element = h('a -drop', {
383
      'ev-click': () => {
384
        const dropTabItems = buildDropdownMenuItems()
385
        const rects = element.getBoundingClientRect()
386
        electron.ipcRenderer.invoke('navigation-menu-popup', {
387
          x: rects.left,
388
          y: rects.bottom,
389
          items: dropTabItems,
390
        })
391
      }
392
    }, title)
393
    return element
394
  }
395
396
  function navigate (href, anchor) {
397
    if (typeof href !== 'string') return false
398
    getExternalHandler(href, (err, handler) => {
399
      if (!err && handler) {
400
        handler(href)
401
      } else {
402
        if (href.startsWith('ssb:')) {
403
          try {
404
            href = ssbUri.toSigilLink(href)
405
          } catch (e) {
406
            // error can be safely ignored
407
            // it just means this isn't an SSB URI
408
          }
409
        }
410
411
        // no external handler found, use page.html.render
412
        previewElement.cancel()
413
        views.setView(href, anchor)
414
      }
415
    })
416
  }
417
418
  function getExternalHandler (href, cb) {
419
    const link = ref.parseLink(href)
420
    if (link && ref.isMsg(link.link)) {
421
      const params = { id: link.link }
422
      if (link.query && link.query.unbox) {
423
        params.private = true
424
        params.unbox = link.query.unbox
425
      }
426
      api.sbot.async.get(params, function (err, value) {
427
        if (err) return cb(err)
428
        cb(null, getGitHandler({ key: link.link, value, query: link.query }))
429
      })
430
    } else if (link && ref.isBlob(link.link)) {
431
      cb(null, function (href) {
432
        electron.shell.openExternal(api.blob.sync.url(href))
433
      })
434
    } else {
435
      cb()
436
    }
437
  }
438
439
  function tab (name, view) {
440
    const instance = views.get(view)
441
    return h('a', {
442
      'ev-click': function () {
443
        const instance = views.get(view)
444
        const isSelected = views.currentView() === view
445
        const needsRefresh = instance && instance.pendingUpdates && instance.pendingUpdates()
446
447
        // refresh if tab is clicked when there are pending items or the page is already selected
448
        if ((needsRefresh || isSelected) && instance.reload) {
449
          instance.reload()
450
        }
451
      },
452
      href: view,
453
      classList: [
454
        when(selected(view), '-selected')
455
      ]
456
    }, [
457
      name,
458
      instance
459
        ? when(instance.pendingUpdates, [' (', instance.pendingUpdates, ')'])
460
        : null
461
    ])
462
  }
463
464
  function selected (view) {
465
    return computed([views.currentView, view], (currentView, view) => {
466
      return currentView === view
467
    })
468
  }
469
470
  function getMessageText (id, cb) {
471
    api.sbot.async.get(id, (err, value) => {
472
      if (err) return cb(err)
473
      if (value.content.type === 'gathering') {
474
        api.about.async.latestValues(id, ['title', 'description'], (err, values) => {
475
          if (err) return cb(err)
476
          const text = `# ${values.title}\n\n${values.description}`
477
          cb(null, text)
478
        })
479
      } else {
480
        cb(null, value.content.text)
481
      }
482
    })
483
  }
484
}
485
486
function overrideConfig (config) {
487
  return {
488
    'patchwork/config': {
489
      gives: nest('config.sync.load'),
490
      create: function () {
491
        return nest('config.sync.load', () => config)
492
      }
493
    }
494
  }
495
}
496
497
function addCommand (id, cb) {
498
  return {
499
    [`patchwork/command/${id}`]: {
500
      gives: nest(id),
501
      create: function () {
502
        return nest(id, cb)
503
      }
504
    }
505
  }
506
}
507
508
function localeCompare (a, b) {
509
  return a.localeCompare(b)
510
}
511
512
function preventDefault (ev) {
513
  ev.preventDefault()
514
}
515
516
function preventDefaultUnlessImage (ev) {
517
  if (ev.target.nodeName !== 'IMG') {
518
    ev.preventDefault()
519
  }
520
}
521