lbry-desktop/ui/redux/actions/subscriptions.js

79 lines
2.5 KiB
JavaScript
Raw Normal View History

2021-06-11 22:49:18 +02:00
// @flow
import * as ACTIONS from 'constants/action_types';
import REWARDS from 'rewards';
import { Lbryio } from 'lbryinc';
import { doClaimRewardType } from 'redux/actions/rewards';
2019-11-19 21:34:25 +01:00
import { parseURI } from 'lbry-redux';
import { doAlertWaitingForSync } from 'redux/actions/app';
2021-06-11 22:49:18 +02:00
import { doToast } from 'redux/actions/notifications';
2017-12-08 21:14:35 +01:00
2021-06-11 22:49:18 +02:00
type SubscriptionArgs = {
channelName: string,
uri: string,
notificationsDisabled?: boolean,
};
2021-06-11 22:49:18 +02:00
export function doToggleSubscription(subscription: SubscriptionArgs, isSubscribed: boolean = false) {
return async (dispatch: Dispatch, getState: GetState) => {
const {
settings: { daemonSettings },
sync: { prefsReady: ready },
} = getState();
2021-06-11 22:49:18 +02:00
if (!ready) {
return dispatch(doAlertWaitingForSync());
}
2021-06-11 22:49:18 +02:00
const { share_usage_data: shareSetting } = daemonSettings;
const isSharingData = shareSetting || IS_WEB;
2018-10-31 18:08:30 +01:00
2021-06-11 22:49:18 +02:00
if (!isSubscribed) {
const subscriptionUri = subscription.uri;
if (!subscriptionUri.startsWith('lbry://')) {
throw Error(`Subscription uris must include the "lbry://" prefix.\nTried to subscribe to ${subscriptionUri}`);
}
}
2021-06-11 22:49:18 +02:00
dispatch({
type: !isSubscribed ? ACTIONS.CHANNEL_SUBSCRIBE : ACTIONS.CHANNEL_UNSUBSCRIBE,
data: subscription,
});
2021-06-11 22:49:18 +02:00
// if the user isn't sharing data, keep the subscriptions entirely in the app
if (isSharingData || IS_WEB) {
const { channelClaimId } = parseURI(subscription.uri);
2021-06-11 22:49:18 +02:00
if (!isSubscribed) {
// They are sharing data, we can store their subscriptions in our internal database
Lbryio.call('subscription', 'new', {
channel_name: subscription.channelName,
claim_id: channelClaimId,
notifications_disabled: subscription.notificationsDisabled,
});
2021-06-11 22:49:18 +02:00
dispatch(doClaimRewardType(REWARDS.TYPE_SUBSCRIPTION, { failSilently: true }));
} else {
Lbryio.call('subscription', 'delete', {
claim_id: channelClaimId,
});
}
}
2021-06-11 22:49:18 +02:00
dispatch(doToast({
message: __(!isSubscribed ? 'You followed %CHANNEL_NAME%!' : 'Unfollowed %CHANNEL_NAME%.', { CHANNEL_NAME: subscription.channelName }),
}));
};
}
2021-06-11 22:49:18 +02:00
export function doChannelSubscribe(subscription: SubscriptionArgs) {
return (dispatch: Dispatch) => {
return dispatch(doToggleSubscription(subscription));
};
}
2021-06-11 22:49:18 +02:00
export function doChannelUnsubscribe(subscription: SubscriptionArgs) {
return (dispatch: Dispatch) => {
return dispatch(doToggleSubscription(subscription, true));
};
}