assets/components/releases/release.vue

@@ -50,20 +50,6 @@
 						icon="question2"
 					/>
 				</h2>
-
-				<Icon
-					v-show="me && isStashed"
-					icon="heart7"
-					class="stash stashed noselect"
-					@click="unstashScene"
-				/>
-
-				<Icon
-					v-show="me && !isStashed"
-					icon="heart8"
-					class="stash unstashed noselect"
-					@click="stashScene"
-				/>
 			</div>
 
 			<div class="row associations">
@@ -237,7 +223,7 @@ import Actor from '../actors/tile.vue';
 import Releases from './releases.vue';
 import Scroll from '../scroll/scroll.vue';
 
-async function fetchRelease(scroll = true) {
+async function fetchRelease() {
 	if (this.$route.name === 'scene') {
 		this.release = await this.$store.dispatch('fetchReleaseById', this.$route.params.releaseId);
 	}
@@ -246,37 +232,11 @@ async function fetchRelease(scroll = true) {
 		this.release = await this.$store.dispatch('fetchMovieById', this.$route.params.releaseId);
 	}
 
-	if (scroll && this.$refs.content) {
+	if (this.$refs.content) {
 		this.$refs.content.scrollTop = 0;
 	}
 }
 
-async function stashScene() {
-	this.$store.dispatch('stashScene', {
-		sceneId: this.release.id,
-		stashId: this.$store.getters.favorites.id,
-	});
-
-	this.fetchRelease(false);
-}
-
-async function unstashScene() {
-	this.$store.dispatch('unstashScene', {
-		sceneId: this.release.id,
-		stashId: this.$store.getters.favorites.id,
-	});
-
-	this.fetchRelease(false);
-}
-
-function me() {
-	return this.$store.state.auth.user;
-}
-
-function isStashed() {
-	return this.release.stashes?.length > 0;
-}
-
 function bannerBackground() {
 	return (this.release.poster && this.getBgPath(this.release.poster, 'thumbnail'))
 		|| (this.release.covers.length > 0 && this.getBgPath(this.release.covers[0], 'thumbnail'));
@@ -311,8 +271,6 @@ export default {
 	computed: {
 		pageTitle,
 		bannerBackground,
-		isStashed,
-		me,
 		showAlbum,
 	},
 	watch: {
@@ -321,8 +279,6 @@ export default {
 	mounted: fetchRelease,
 	methods: {
 		fetchRelease,
-		stashScene,
-		unstashScene,
 	},
 };
 </script>
@@ -397,22 +353,6 @@ export default {
 	color: var(--shadow);
 }
 
-.stash.icon {
-	width: 1.5rem;
-	height: 1.5rem;
-	padding: 0 1rem;
-	fill: var(--darken);
-
-	&.stashed {
-		fill: var(--primary);
-	}
-
-	&:hover {
-		fill: var(--primary);
-		cursor: pointer;
-	}
-}
-
 .album-toggle {
 	height: fit-content;
 	display: inline-flex;

assets/js/fragments.js

@@ -346,21 +346,6 @@ const releaseFragment = `
 			}
 		}
 	}
-	stashes: stashesScenesBySceneId(
-		filter: {
-			stash: {
-				userId: {
-					equalTo: $userId
-				}
-			}
-		}
-	) @include(if: $hasAuth) {
-		stash {
-			id
-			name
-			slug
-		}
-	}
   }
 `;
 

assets/js/releases/actions.js

@@ -37,17 +37,11 @@ function initReleasesActions(store, router) {
 		// const release = await get(`/releases/${releaseId}`);
 
 		const { release } = await graphql(`
-            query Release(
-				$releaseId: Int!
-				$hasAuth: Boolean!
-				$userId: Int
-			) {
+            query Release($releaseId:Int!) {
                 ${releaseFragment}
             }
         `, {
 			releaseId: Number(releaseId),
-			hasAuth: !!store.state.auth.user,
-			userId: store.state.auth.user?.id,
 		});
 
 		if (!release) {

assets/js/stashes/actions.js

@@ -9,19 +9,9 @@ function initStashesActions(_store, _router) {
 		await del(`/stashes/${stashId}/actors/${actorId}`);
 	}
 
-	async function stashScene(context, { sceneId, stashId }) {
-		await post(`/stashes/${stashId}/scenes`, { sceneId });
-	}
-
-	async function unstashScene(context, { sceneId, stashId }) {
-		await del(`/stashes/${stashId}/scenes/${sceneId}`);
-	}
-
 	return {
 		stashActor,
-		stashScene,
 		unstashActor,
-		unstashScene,
 	};
 }
 

assets/js/users/actions.js

@@ -1,6 +1,4 @@
 import { graphql } from '../api';
-import { releaseFields } from '../fragments';
-import { curateUser } from '../curate';
 
 function initUsersActions(_store, _router) {
 	async function fetchUser(context, username) {
@@ -45,7 +43,45 @@ function initUsersActions(_store, _router) {
 						scenes: stashesScenes {
 							comment
 							scene {
-								${releaseFields}
+								id
+								title
+								slug
+								url
+								date
+								actors: releasesActors {
+									actor {
+										id
+										name
+										slug
+									}
+								}
+								tags: releasesTags {
+									tag {
+										id
+										name
+										slug
+									}
+								}
+								entity {
+									id
+									name
+									slug
+									independent
+									parent {
+										id
+										name
+										slug
+										independent
+									}
+								}
+								poster: releasesPosterByReleaseId {
+									media {
+										path
+										thumbnail
+										lazy
+										isS3
+									}
+								}
 							}
 						}
 					}
@@ -55,7 +91,7 @@ function initUsersActions(_store, _router) {
 			username,
 		});
 
-		return curateUser(user);
+		return user;
 	}
 
 	return {

migrations/20190325001339_releases.js

@@ -1328,6 +1328,7 @@ exports.up = knex => Promise.resolve()
 				));
 		`, {
 			visitor: knex.raw(config.database.query.user),
+			password: knex.raw(config.database.query.password),
 		});
 	})
 	// VIEWS AND COMMENTS

package-lock.json

@@ -1,11 +1,11 @@
 {
     "name": "traxxx",
-    "version": "1.186.0",
+    "version": "1.185.1",
     "lockfileVersion": 2,
     "requires": true,
     "packages": {
         "": {
-            "version": "1.186.0",
+            "version": "1.185.1",
             "license": "ISC",
             "dependencies": {
                 "@casl/ability": "^5.2.2",

package.json

@@ -1,6 +1,6 @@
 {
     "name": "traxxx",
-    "version": "1.186.0",
+    "version": "1.185.1",
     "description": "All the latest porn releases in one place",
     "main": "src/app.js",
     "scripts": {

src/app.js

@@ -21,7 +21,7 @@ function logActive() {
 	setTimeout(() => {
 		log();
 		logActive();
-	}, argv.logActive || 60000);
+	}, 600000);
 }
 
 async function init() {

src/stashes.js

@@ -48,31 +48,19 @@ async function stashScene(sceneId, stashId, sessionUser) {
 	await knex('stashes_scenes')
 		.insert({
 			stash_id: stash.id,
-			scene_id: sceneId,
+			actor_id: sceneId,
 		});
 }
 
 async function unstashActor(actorId, stashId, sessionUser) {
 	await knex
-		.from('stashes_actors AS deletable')
-		.where('deletable.actor_id', actorId)
-		.where('deletable.stash_id', stashId)
-		.whereExists(knex('stashes_actors') // verify user owns this stash
+		.from('stashes_actors')
+		.whereIn('stashes_actors.id', knex('stashes_actors')
+			.select('stashes_actors.id')
 			.leftJoin('stashes', 'stashes.id', 'stashes_actors.stash_id')
-			.where('stashes_actors.stash_id', knex.raw('deletable.stash_id'))
-			.where('stashes.user_id', sessionUser.id))
-		.delete();
-}
-
-async function unstashScene(sceneId, stashId, sessionUser) {
-	await knex
-		.from('stashes_scenes AS deletable')
-		.where('deletable.scene_id', sceneId)
-		.where('deletable.stash_id', stashId)
-		.whereExists(knex('stashes_scenes') // verify user owns this stash
-			.leftJoin('stashes', 'stashes.id', 'stashes_scenes.stash_id')
-			.where('stashes_scenes.stash_id', knex.raw('deletable.stash_id'))
-			.where('stashes.user_id', sessionUser.id))
+			.where('stashes.user_id', sessionUser.id) // verify user owns this stash
+			.where('stashes_actors.actor_id', actorId)
+			.where('stashes_actors.stash_id', stashId))
 		.delete();
 }
 
@@ -80,6 +68,6 @@ module.exports = {
 	curateStash,
 	stashActor,
 	stashScene,
-	unstashScene,
+	// unstashScene,
 	unstashActor,
 };

src/utils/http.js

@@ -80,9 +80,20 @@ function getLimiter(options = {}, url) {
 	return limiters[interval][concurrency];
 }
 
-async function request(method = 'get', url, body, requestOptions = {}, limiter) {
+async function request(method = 'get', url, body, requestOptions = {}, limiter, timeout) {
 	const http = requestOptions.session || bhttp;
-	const options = requestOptions;
+
+	const options = {
+		...defaultOptions,
+		...requestOptions,
+		headers: {
+			...defaultOptions.headers,
+			...requestOptions.headers,
+		},
+		responseTimeout: requestOptions.responseTimeout || requestOptions.timeout || defaultOptions.timeout,
+		stream: !!requestOptions.destination,
+		session: null,
+	};
 
 	const withProxy = useProxy(url);
 
@@ -96,10 +107,8 @@ async function request(method = 'get', url, body, requestOptions = {}, limiter)
 		? http[method](url, body, options)
 		: http[method](url, options));
 
-	return res;
-}
+	timeout.cancel();
 
-async function finalizeResult(res, options) {
 	if (options.destination) {
 		// res.on('progress', (bytes, totalBytes) => logger.silly(`Downloaded ${Math.round((bytes / totalBytes) * 100)}% of ${url}`));
 
@@ -131,39 +140,21 @@ async function finalizeResult(res, options) {
 
 function getTimeout(options, url) {
 	return new Promise((resolve, reject, onCancel) => {
-		const timeout = setTimeout(() => {
+		const timeoutId = setTimeout(() => {
 			reject(new Error(`URL ${url} timed out`));
 		}, (options?.timeout || defaultOptions.timeout) + 10000);
 
-		onCancel(() => {
-			clearTimeout(timeout);
-		});
+		onCancel(() => clearTimeout(timeoutId));
 	});
 }
 
-async function scheduleRequest(method = 'get', url, body, requestOptions = {}) {
-	const options = {
-		...defaultOptions,
-		...requestOptions,
-		headers: {
-			...defaultOptions.headers,
-			...requestOptions.headers,
-		},
-		responseTimeout: requestOptions.responseTimeout || requestOptions.timeout || defaultOptions.timeout,
-		stream: !!requestOptions.destination,
-		session: null,
-	};
-
+async function scheduleRequest(method = 'get', url, body, options) {
 	const limiter = getLimiter(options, url);
 	const timeout = getTimeout(options, url);
 
-	const result = await limiter.schedule(async () => Promise.race([request(method, url, body, options, limiter), timeout]));
+	const result = await limiter.schedule(() => Promise.race([request(method, url, body, options, limiter, timeout), timeout]));
 
-	timeout.cancel();
-
-	const curatedResult = await finalizeResult(result, options);
-
-	return curatedResult;
+	return result;
 }
 
 async function get(url, options) {