Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
export default async function groups(_, { shopId, ...connectionArgs }, context, info) {
// Transform ID from base64
const dbShopId = decodeShopOpaqueId(shopId);
const query = await context.queries.groups(context, dbShopId);
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
export default async function navigationItemsByShopId(_, args, context, info) {
const { shopId, ...connectionArgs } = args;
const decodedShopId = decodeShopOpaqueId(shopId);
const query = await context.queries.navigationItemsByShopId(context, decodedShopId);
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
productIds,
shopIds,
tagIds,
query: queryString,
isArchived,
isVisible,
metafieldKey,
metafieldValue,
priceMin,
priceMax
});
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
serviceNames,
shopId: opaqueShopId,
...connectionArgs
} = args;
const shopId = decodeShopOpaqueId(opaqueShopId);
const cursor = await context.queries.addressValidationRules(context, {
serviceNames,
shopId
});
return getPaginatedResponse(cursor, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
export default async function tags(cartItem, connectionArgs, context, info) {
const { productTagIds } = cartItem;
if (!productTagIds || productTagIds.length === 0) return xformArrayToConnection(connectionArgs, []);
const query = await context.queries.tagsByIds(context, productTagIds, connectionArgs);
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
export default async function ordersByAccountId(parentResult, args, context, info) {
const { accountId, orderStatus, shopIds: opaqueShopIds, ...connectionArgs } = args;
const shopIds = opaqueShopIds && opaqueShopIds.map(decodeShopOpaqueId);
const query = await context.queries.ordersByAccountId(context, {
accountId: decodeAccountOpaqueId(accountId),
orderStatus,
shopIds
});
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
export default async function productTags(orderItem, connectionArgs, context, info) {
const { productTagIds } = orderItem;
if (!productTagIds || productTagIds.length === 0) return xformArrayToConnection(connectionArgs, []);
const query = await context.queries.tagsByIds(context, productTagIds, connectionArgs);
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
export default async function orders(parentResult, args, context, info) {
const { filters, shopIds: opaqueShopIds, ...connectionArgs } = args;
const shopIds = opaqueShopIds && opaqueShopIds.map(decodeShopOpaqueId);
const query = await context.queries.orders(context, {
filters,
shopIds
});
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
export default async function tags(product, connectionArgs, context, info) {
const { tagIds } = product;
if (!tagIds || tagIds.length === 0) return xformArrayToConnection(connectionArgs, []);
const query = await context.queries.tagsByIds(context, tagIds, connectionArgs);
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}
"Verify that you have a pricing plugin installed and it registers a getMinPriceSortByFieldPath function.");
throw new ReactionError("invalid-parameter", "Sorting by minPrice is not supported");
}
connectionArgs.sortBy = realSortByField;
}
const query = await context.queries.catalogItems(context, {
catalogBooleanFilters,
shopIds,
tagIds
});
return getPaginatedResponse(query, connectionArgs, {
includeHasNextPage: wasFieldRequested("pageInfo.hasNextPage", info),
includeHasPreviousPage: wasFieldRequested("pageInfo.hasPreviousPage", info),
includeTotalCount: wasFieldRequested("totalCount", info)
});
}