Notifications Service

package.json

@@ -45,6 +45,7 @@
     "cross-env": "^5.1.1",
     "date-fns": "^2.15.0",
     "debug": "^3.2.7",
+    "events": "^3.3.0",
     "express": "^4.17.1",
     "express-session": "^1.17.1",
     "express-slow-down": "^1.3.1",

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

@@ -123,6 +123,7 @@ class CollectionPage extends React.Component {
 		super(props);
 		this.state = {
 			entities: this.props.entities,
+			isSubscribed: false,
 			message: {
 				text: null,
 				type: null
@@ -138,13 +139,20 @@ class CollectionPage extends React.Component {
 		this.handleRemoveEntities = this.handleRemoveEntities.bind(this);
 		this.handleShowDeleteModal = this.handleShowDeleteModal.bind(this);
 		this.handleCloseDeleteModal = this.handleCloseDeleteModal.bind(this);
+		this.handleSubscribe = this.handleSubscribe.bind(this);
 		this.handleShowAddEntityModal = this.handleShowAddEntityModal.bind(this);
 		this.handleCloseAddEntityModal = this.handleCloseAddEntityModal.bind(this);
 		this.handleAlertDismiss = this.handleAlertDismiss.bind(this);
+		this.handleUnsubscribe = this.handleUnsubscribe.bind(this);
 		this.searchResultsCallback = this.searchResultsCallback.bind(this);
+		this.setIsSubscribed = this.setIsSubscribed.bind(this);
 		this.closeAddEntityModalShowMessageAndRefreshTable = this.closeAddEntityModalShowMessageAndRefreshTable.bind(this);
 	}
 
+	async componentDidMount() {
+		await this.setIsSubscribed();
+	}
+
 	searchResultsCallback(newResults) {
 		this.setState({entities: newResults});
 	}
@@ -224,6 +232,59 @@ class CollectionPage extends React.Component {
 		}, this.pagerElementRef.triggerSearch);
 	}
 
+	handleSubscribe() {
+		const submissionUrl = '/subscription/subscribe/collection';
+		const collectionId = this.props.collection.id;
+		const subscriberId = this.props.userId;
+		request.post(submissionUrl)
+			.send({collectionId, subscriberId})
+			.then((res) => {
+				const {isSubscribed} = res.body;
+				this.setState({isSubscribed});
+			}, () => {
+				this.setState({
+					message: {
+						text: 'Something went wrong! Please try again later',
+						type: 'danger'
+					}
+				});
+			});
+	}
+
+	handleUnsubscribe() {
+		const submissionUrl = '/subscription/unsubscribe/collection';
+		const collectionId = this.props.collection.id;
+		request.post(submissionUrl)
+			.send({collectionId})
+			.then((res) => {
+				const {isSubscribed} = res.body;
+				this.setState({isSubscribed});
+			}, () => {
+				this.setState({
+					message: {
+						text: 'Something went wrong! Please try again later',
+						type: 'danger'
+					}
+				});
+			});
+	}
+
+	setIsSubscribed() {
+		const url = `/subscription/collection/isSubscribed/${this.props.collection.id}`;
+		request.get(url)
+			.then(res => {
+				const {isSubscribed} = res.body;
+				this.setState({isSubscribed});
+			}, () => {
+				this.setState({
+					message: {
+						text: 'Something went wrong! Please try again later',
+						type: 'danger'
+					}
+				});
+			});
+	}
+
 	render() {
 		const messageComponent = this.state.message.text ? <Alert bsStyle={this.state.message.type} className="margin-top-1" onDismiss={this.handleAlertDismiss}>{this.state.message.text}</Alert> : null;
 		const EntityTable = getEntityTable(this.props.collection.entityType);
@@ -262,6 +323,30 @@ class CollectionPage extends React.Component {
 						<CollectionAttributes collection={this.props.collection}/>
 					</Col>
 				</Row>
+				{
+					!this.state.isSubscribed &&
+						<Button
+							bsSize="small"
+							bsStyle="success"
+							className="margin-bottom-d5"
+							title="Subscribe"
+							onClick={this.handleSubscribe}
+						>
+							Subscribe
+						</Button>
+				}
+				{
+					this.state.isSubscribed &&
+						<Button
+							bsSize="small"
+							bsStyle="danger"
+							className="margin-bottom-d5"
+							title="Unsubscribe"
+							onClick={this.handleUnsubscribe}
+						>
+							Unsubscribe
+						</Button>
+				}
 				<EntityTable{...propsForTable}/>
 				{messageComponent}
 				<div className="margin-top-1 text-left">

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

@@ -18,7 +18,7 @@
 
 import * as bootstrap from 'react-bootstrap';
 import * as entityHelper from '../../../helpers/entity';
-
+import React, {useEffect, useState} from 'react';
 import EntityAnnotation from './annotation';
 import EntityFooter from './footer';
 import EntityImage from './image';
@@ -27,10 +27,10 @@ import EntityRelatedCollections from './related-collections';
 import EntityTitle from './title';
 import {FontAwesomeIcon} from '@fortawesome/react-fontawesome';
 import PropTypes from 'prop-types';
-import React from 'react';
 import {kebabCase as _kebabCase} from 'lodash';
 import {faPlus} from '@fortawesome/free-solid-svg-icons';
 import {labelsForAuthor} from '../../../helpers/utils';
+import request from 'superagent';
 
 
 const {deletedEntityMessage, extractAttribute, getTypeAttribute, getEntityUrl,
@@ -109,6 +109,38 @@ AuthorAttributes.propTypes = {
 
 function AuthorDisplayPage({entity, identifierTypes, user}) {
 	const urlPrefix = getEntityUrl(entity);
+	const [isSubscribed, setIsSubscribed] = useState(false);
+	useEffect(() => {
+		request.get(`/subscription/entity/isSubscribed/${entity.bbid}`).then(response => {
+			if (response.body.isSubscribed) {
+				setIsSubscribed(true);
+			}
+		});
+	});
+	function handleUnsubscribe(bbid) {
+		const submissionUrl = '/subscription/unsubscribe/entity';
+		request.post(submissionUrl)
+			.send({bbid})
+			.then((res) => {
+				setIsSubscribed(false);
+			}, (error) => {
+				// eslint-disable-next-line no-console
+				console.log('error thrown');
+			});
+	}
+	function handleSubscribe(bbid) {
+		const submissionUrl = '/subscription/subscribe/entity';
+		request.post(submissionUrl)
+			.send({bbid})
+			.then((res) => {
+				setIsSubscribed(true);
+			}, (error) => {
+				// eslint-disable-next-line no-console
+				console.log('error thrown');
+			});
+	}
+
+	/* eslint-disable react/jsx-no-bind */
 	return (
 		<div>
 			<Row className="entity-display-background">
@@ -124,6 +156,26 @@ function AuthorDisplayPage({entity, identifierTypes, user}) {
 					<AuthorAttributes author={entity}/>
 				</Col>
 			</Row>
+			{
+				!isSubscribed &&
+					<Button
+						bsStyle="success"
+						className="margin-top-d15"
+						onClick={() => handleSubscribe(entity.bbid)}
+					>
+						Subscribe
+					</Button>
+			}
+			{
+				isSubscribed &&
+					<Button
+						bsStyle="danger"
+						className="margin-top-d15"
+						onClick={() => handleUnsubscribe(entity.bbid)}
+					>
+						Unsubscribe
+					</Button>
+			}
 			<EntityAnnotation entity={entity}/>
 			{!entity.deleted &&
 			<React.Fragment>

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

@@ -18,6 +18,7 @@
 
 import * as bootstrap from 'react-bootstrap';
 import * as entityHelper from '../../../helpers/entity';
+import React, {useEffect, useState} from 'react';
 import EditionTable from './edition-table';
 import EntityAnnotation from './annotation';
 import EntityFooter from './footer';
@@ -26,11 +27,11 @@ import EntityLinks from './links';
 import EntityRelatedCollections from './related-collections';
 import EntityTitle from './title';
 import PropTypes from 'prop-types';
-import React from 'react';
+import request from 'superagent';
 
 
 const {deletedEntityMessage, getTypeAttribute, getEntityUrl, ENTITY_TYPE_ICONS, getSortNameOfDefaultAlias} = entityHelper;
-const {Col, Row} = bootstrap;
+const {Col, Row, Button} = bootstrap;
 
 function EditionGroupAttributes({editionGroup}) {
 	if (editionGroup.deleted) {
@@ -65,6 +66,38 @@ EditionGroupAttributes.propTypes = {
 
 function EditionGroupDisplayPage({entity, identifierTypes, user}) {
 	const urlPrefix = getEntityUrl(entity);
+	const [isSubscribed, setIsSubscribed] = useState(false);
+	useEffect(() => {
+		request.get(`/subscription/entity/isSubscribed/${entity.bbid}`).then(response => {
+			if (response.body.isSubscribed) {
+				setIsSubscribed(true);
+			}
+		});
+	});
+	function handleUnsubscribe(bbid) {
+		const submissionUrl = '/subscription/unsubscribe/entity';
+		request.post(submissionUrl)
+			.send({bbid})
+			.then((res) => {
+				setIsSubscribed(false);
+			}, (error) => {
+				// eslint-disable-next-line no-console
+				console.log('error thrown');
+			});
+	}
+	function handleSubscribe(bbid) {
+		const submissionUrl = '/subscription/subscribe/entity';
+		request.post(submissionUrl)
+			.send({bbid})
+			.then((res) => {
+				setIsSubscribed(true);
+			}, (error) => {
+				// eslint-disable-next-line no-console
+				console.log('error thrown');
+			});
+	}
+
+	/* eslint-disable react/jsx-no-bind */
 	return (
 		<div>
 			<Row className="entity-display-background">
@@ -80,6 +113,26 @@ function EditionGroupDisplayPage({entity, identifierTypes, user}) {
 					<EditionGroupAttributes editionGroup={entity}/>
 				</Col>
 			</Row>
+			{
+				!isSubscribed &&
+				<Button
+					bsStyle="success"
+					className="margin-top-d15"
+					onClick={() => handleSubscribe(entity.bbid)}
+				>
+					Subscribe
+				</Button>
+			}
+			{
+				isSubscribed &&
+				<Button
+					bsStyle="danger"
+					className="margin-top-d15"
+					onClick={() => handleUnsubscribe(entity.bbid)}
+				>
+					Unsubscribe
+				</Button>
+			}
 			<EntityAnnotation entity={entity}/>
 			{!entity.deleted &&
 			<React.Fragment>