Notifications Service

package.json

@@ -46,6 +46,7 @@
     "cross-env": "^7.0.3",
     "date-fns": "^2.15.0",
     "debug": "^4.3.2",
+    "events": "^3.3.0",
     "express": "^4.17.2",
     "express-session": "^1.17.1",
     "express-slow-down": "^1.3.1",
@@ -69,6 +70,7 @@
     "react-datepicker": "^4.7.0",
     "react-dom": "^16.13.1",
     "react-hot-loader": "^4.13.0",
+    "react-infinite-scroller": "^1.2.5",
     "react-redux": "^7.2.6",
     "react-select": "^1.1.0",
     "react-select-fast-filter-options": "^0.2.3",

sql/migrations/2021-09-notification-service/down.sql

@@ -0,0 +1,7 @@
+BEGIN;
+
+DROP TABLE IF EXISTS bookbrainz.notification;
+DROP TABLE IF EXISTS bookbrainz.entity_subscription;
+DROP TABLE IF EXISTS bookbrainz.collection_subscription;
+
+COMMIT;

sql/migrations/2021-09-notification-service/up.sql

@@ -0,0 +1,36 @@
+BEGIN;
+
+CREATE TABLE IF NOT EXISTS bookbrainz.notification (
+    id UUID PRIMARY KEY DEFAULT public.uuid_generate_v4(),
+    subscriber_id INT NOT NULL,
+    read BOOLEAN NOT NULL DEFAULT FALSE,
+    notification_text TEXT NOT NULL CHECK (notification_text <> ''),
+    notification_redirect_link TEXT NOT NULL CHECK (notification_redirect_link <> ''),
+    timestamp TIMESTAMP WITHOUT TIME ZONE NOT NULL DEFAULT timezone('UTC'::TEXT, now())
+);
+ALTER TABLE bookbrainz.notification ADD FOREIGN KEY (subscriber_id) REFERENCES  bookbrainz.editor (id);
+
+CREATE TABLE bookbrainz.entity_subscription (
+    bbid UUID,
+    subscriber_id INT,
+    PRIMARY KEY (
+        bbid,
+        subscriber_id
+    )
+);
+ALTER TABLE bookbrainz.entity_subscription ADD FOREIGN KEY (bbid) REFERENCES bookbrainz.entity (bbid);
+ALTER TABLE bookbrainz.entity_subscription ADD FOREIGN KEY (subscriber_id) REFERENCES bookbrainz.editor (id);
+
+
+CREATE TABLE bookbrainz.collection_subscription (
+    collection_id UUID,
+    subscriber_id INT,
+    PRIMARY KEY (
+        collection_id,
+        subscriber_id
+    )
+);
+ALTER TABLE bookbrainz.collection_subscription ADD FOREIGN KEY (collection_id) REFERENCES bookbrainz.user_collection (id);
+ALTER TABLE bookbrainz.collection_subscription ADD FOREIGN KEY (subscriber_id) REFERENCES bookbrainz.editor (id);
+
+COMMIT;

src/client/components/pages/collection.js

@@ -27,6 +27,8 @@ import {FontAwesomeIcon} from '@fortawesome/react-fontawesome';
 import PagerElement from './parts/pager';
 import PropTypes from 'prop-types';
 import React from 'react';
+import SubscribeButton from './../subscribe-button';
+import WorkTable from './entities/work-table';
 import _ from 'lodash';
 import request from 'superagent';
 
@@ -248,6 +250,7 @@ class CollectionPage extends React.Component {
 						<CollectionAttributes collection={this.props.collection}/>
 					</Col>
 				</Row>
+				<SubscribeButton id={this.props.collection.id} type="collection"/>
 				<EntityTable {...propsForTable}/>
 				{messageComponent}
 				<div className="margin-top-1 text-left">

src/client/components/pages/entities/author.js

@@ -18,7 +18,6 @@
 
 import * as bootstrap from 'react-bootstrap';
 import * as entityHelper from '../../../helpers/entity';
-
 import EntityAnnotation from './annotation';
 import EntityFooter from './footer';
 import EntityImage from './image';
@@ -28,6 +27,7 @@ import EntityTitle from './title';
 import {FontAwesomeIcon} from '@fortawesome/react-fontawesome';
 import PropTypes from 'prop-types';
 import React from 'react';
+import SubscribeButton from '../../subscribe-button';
 import {kebabCase as _kebabCase} from 'lodash';
 import {faPlus} from '@fortawesome/free-solid-svg-icons';
 import {labelsForAuthor} from '../../../helpers/utils';
@@ -124,6 +124,7 @@ function AuthorDisplayPage({entity, identifierTypes, user}) {
 					<AuthorAttributes author={entity}/>
 				</Col>
 			</Row>
+			<SubscribeButton id={entity.bbid} type="author"/>
 			<EntityAnnotation entity={entity}/>
 			{!entity.deleted &&
 			<React.Fragment>

src/client/components/pages/entities/edition-group.js

@@ -27,6 +27,7 @@ import EntityRelatedCollections from './related-collections';
 import EntityTitle from './title';
 import PropTypes from 'prop-types';
 import React from 'react';
+import SubscribeButton from '../../subscribe-button';
 
 
 const {deletedEntityMessage, getTypeAttribute, getEntityUrl, ENTITY_TYPE_ICONS, getSortNameOfDefaultAlias} = entityHelper;
@@ -80,6 +81,7 @@ function EditionGroupDisplayPage({entity, identifierTypes, user}) {
 					<EditionGroupAttributes editionGroup={entity}/>
 				</Col>
 			</Row>
+			<SubscribeButton id={entity.bbid} type="editionGroup"/>
 			<EntityAnnotation entity={entity}/>
 			{!entity.deleted &&
 			<React.Fragment>

src/client/components/pages/entities/edition.js

@@ -27,6 +27,7 @@ import EntityTitle from './title';
 import {FontAwesomeIcon} from '@fortawesome/react-fontawesome';
 import PropTypes from 'prop-types';
 import React from 'react';
+import SubscribeButton from '../../subscribe-button';
 import WorksTable from './work-table';
 import {faExternalLinkAlt} from '@fortawesome/free-solid-svg-icons';
 
@@ -145,6 +146,7 @@ function EditionDisplayPage({entity, identifierTypes, user}) {
 					{editionGroupSection}
 				</Col>
 			</Row>
+			<SubscribeButton id={entity.bbid} type="edition"/>
 			<EntityAnnotation entity={entity}/>
 			{!entity.deleted &&
 			<React.Fragment>

src/client/components/pages/entities/publisher.js

@@ -27,6 +27,7 @@ import EntityRelatedCollections from './related-collections';
 import EntityTitle from './title';
 import PropTypes from 'prop-types';
 import React from 'react';
+import SubscribeButton from '../../subscribe-button';
 
 
 const {deletedEntityMessage, extractAttribute, getTypeAttribute, getEntityUrl,
@@ -98,6 +99,7 @@ function PublisherDisplayPage({entity, identifierTypes, user}) {
 					<PublisherAttributes publisher={entity}/>
 				</Col>
 			</Row>
+			<SubscribeButton id={entity.bbid} type="publisher"/>
 			<EntityAnnotation entity={entity}/>
 			{!entity.deleted &&
 			<React.Fragment>

src/client/components/pages/entities/work.js

@@ -28,6 +28,7 @@ import EntityRelatedCollections from './related-collections';
 import EntityTitle from './title';
 import PropTypes from 'prop-types';
 import React from 'react';
+import SubscribeButton from '../../subscribe-button';
 
 
 const {deletedEntityMessage, getRelationshipSourceByTypeId, getLanguageAttribute, getTypeAttribute, getEntityUrl,
@@ -93,6 +94,7 @@ function WorkDisplayPage({entity, identifierTypes, user}) {
 					<WorkAttributes work={entity}/>
 				</Col>
 			</Row>
+			<SubscribeButton id={entity.bbid} type="work"/>
 			<EntityAnnotation entity={entity}/>
 			{!entity.deleted &&
 			<React.Fragment>

src/client/components/subscribe-button.tsx

@@ -0,0 +1,55 @@
+import {Button} from 'react-bootstrap';
+import React from 'react';
+import request from 'superagent';
+
+
+type SubscribeButtonProps = {
+    id:string,
+	type:string,
+};
+function SubscribeButton({id, type}:SubscribeButtonProps) {
+	/* eslint-disable react/jsx-no-bind */
+	const [isSubscribed, setIsSubscribed] = React.useState(false);
+	React.useEffect(() => {
+		request.get(`/${type}/${id}/subscribed`).then(response => {
+			if (response.body.isSubscribed) {
+				setIsSubscribed(true);
+			}
+		});
+	});
+	function handleUnsubscribe() {
+		const submissionUrl = `/${type}/${id}/unsubscribe`;
+		request.post(submissionUrl)
+			.then(() => {
+				setIsSubscribed(false);
+			});
+	}
+	function handleSubscribe() {
+		const submissionUrl = `/${type}/${id}/subscribe`;
+		request.post(submissionUrl)
+			.then(() => {
+				setIsSubscribed(true);
+			});
+	}
+	if (!isSubscribed) {
+		return (
+			<Button
+				className="margin-top-d15"
+				variant="success"
+				onClick={() => handleSubscribe()}
+			>
+        Subscribe
+			</Button>);
+	}
+
+	return (
+		<Button
+			className="margin-top-d15"
+			variant="danger"
+			onClick={() => handleUnsubscribe()}
+		>
+        Unsubscribe
+		</Button>);
+}
+
+export default SubscribeButton;