lib/repos/index.jsView |
---|
109 | 109 … | return h('div', [ |
110 | 110 … | pull( |
111 | 111 … | cat([ |
112 | 112 … | pull.once(msg), |
113 | | - self.web.ssb.links({ |
| 113 … | + self.web.ssb.backlinks ? self.web.ssb.backlinks.read({ |
| 114 … | + query: [ |
| 115 … | + {$filter: { |
| 116 … | + dest: root |
| 117 … | + }} |
| 118 … | + ] |
| 119 … | + }) : self.web.ssb.links({ |
114 | 120 … | dest: root, |
115 | 121 … | values: true |
116 | 122 … | }), |
117 | 123 … | ]), |
443 | 449 … | var title = req._t('Activity') + ' · %{author}/%{repo}' |
444 | 450 … | return self.serveRepoTemplate(req, repo, 'activity', branch, title, cat([ |
445 | 451 … | h('h3', req._t('Activity')), |
446 | 452 … | pull( |
447 | | - self.web.ssb.links({ |
| 453 … | + self.web.ssb.backlinks ? self.web.ssb.backlinks.read({ |
| 454 … | + query: [ |
| 455 … | + {$filter: { |
| 456 … | + dest: repo.id, |
| 457 … | + value: { |
| 458 … | + content: { |
| 459 … | + repo: repo.id |
| 460 … | + } |
| 461 … | + } |
| 462 … | + }} |
| 463 … | + ] |
| 464 … | + }) : self.web.ssb.links({ |
448 | 465 … | dest: repo.id, |
449 | 466 … | rel: 'repo', |
450 | 467 … | values: true |
451 | 468 … | }), |
1105 | 1122 … | cat([ |
1106 | 1123 … | includeSelf && pull.once(repo.id), |
1107 | 1124 … | |
1108 | 1125 … | pull( |
1109 | | - self.web.ssb.links({ |
1110 | | - dest: repo.id, |
1111 | | - rel: 'upstream' |
1112 | | - }), |
1113 | | - pull.map('key') |
| 1126 … | + self.web.ssb.backlinks ? self.web.ssb.backlinks.read({ |
| 1127 … | + query: [ |
| 1128 … | + {$filter: { |
| 1129 … | + dest: repo.id, |
| 1130 … | + value: { |
| 1131 … | + content: { |
| 1132 … | + type: 'git-repo', |
| 1133 … | + upstream: repo.id, |
| 1134 … | + } |
| 1135 … | + } |
| 1136 … | + }}, |
| 1137 … | + {$map: 'key'} |
| 1138 … | + ] |
| 1139 … | + }) : pull( |
| 1140 … | + self.web.ssb.links({ |
| 1141 … | + dest: repo.id, |
| 1142 … | + rel: 'upstream' |
| 1143 … | + }), |
| 1144 … | + pull.map('key') |
| 1145 … | + ) |
1114 | 1146 … | ), |
1115 | 1147 … | |
1116 | 1148 … | pull( |
1117 | | - self.web.ssb.links({ |
1118 | | - dest: repo.id, |
1119 | | - values: true, |
1120 | | - rel: 'project' |
1121 | | - }), |
1122 | | - u.decryptMessages(self.web.ssb), |
1123 | | - pull.filter(function (msg) { |
1124 | | - var c = msg && msg.value && msg.value.content |
1125 | | - return c && c.type == 'pull-request' |
1126 | | - }), |
| 1149 … | + self.web.ssb.backlinks ? self.web.ssb.backlinks.read({ |
| 1150 … | + query: [ |
| 1151 … | + {$filter: { |
| 1152 … | + dest: repo.id, |
| 1153 … | + value: { |
| 1154 … | + content: { |
| 1155 … | + type: 'pull-request', |
| 1156 … | + project: repo.id, |
| 1157 … | + } |
| 1158 … | + } |
| 1159 … | + }} |
| 1160 … | + ] |
| 1161 … | + }) : pull( |
| 1162 … | + self.web.ssb.links({ |
| 1163 … | + dest: repo.id, |
| 1164 … | + values: true, |
| 1165 … | + rel: 'project' |
| 1166 … | + }), |
| 1167 … | + u.decryptMessages(self.web.ssb), |
| 1168 … | + pull.filter(function (msg) { |
| 1169 … | + var c = msg && msg.value && msg.value.content |
|
| 1170 … | + return c && c.type == 'pull-request' |
| 1171 … | + }) |
| 1172 … | + ), |
1127 | 1173 … | pull.map(function (msg) { return msg.value.content.head_repo }) |
1128 | 1174 … | ) |
1129 | 1175 … | ]), |
1130 | 1176 … | pull.unique(), |
1131 | 1177 … | paramap(function (key, cb) { |
| 1178 … | + if (key && key[0] === '#') return cb(null, {key: key, value: { |
| 1179 … | + content: { |
| 1180 … | + type: 'git-repo', |
| 1181 … | + } |
| 1182 … | + }}) |
1132 | 1183 … | self.web.getMsg(key, cb) |
1133 | 1184 … | }, 4), |
1134 | 1185 … | u.decryptMessages(self.web.ssb), |
1135 | 1186 … | pull.filter(function (msg) { |