WIP
This commit is contained in:
parent
d60fb081c9
commit
7b43ac4558
|
@ -68,6 +68,7 @@
|
||||||
"test-e2e:embed-react": "yarn db-seed && yarn e2e:embed-react",
|
"test-e2e:embed-react": "yarn db-seed && yarn e2e:embed-react",
|
||||||
"test-playwright": "yarn playwright test --config=playwright.config.ts",
|
"test-playwright": "yarn playwright test --config=playwright.config.ts",
|
||||||
"test": "vitest run",
|
"test": "vitest run",
|
||||||
|
"test:int": "packages/features/bookings/tests/integration-test.sh",
|
||||||
"type-check": "turbo run type-check",
|
"type-check": "turbo run type-check",
|
||||||
"type-check:ci": "turbo run type-check:ci --log-prefix=none",
|
"type-check:ci": "turbo run type-check:ci --log-prefix=none",
|
||||||
"web": "yarn workspace @calcom/web"
|
"web": "yarn workspace @calcom/web"
|
||||||
|
|
|
@ -239,6 +239,7 @@ function checkForConflicts(busyTimes: BufferedBusyTimes, time: dayjs.ConfigType,
|
||||||
}
|
}
|
||||||
|
|
||||||
const getEventTypesFromDB = async (eventTypeId: number) => {
|
const getEventTypesFromDB = async (eventTypeId: number) => {
|
||||||
|
console.log("🚀 ~ file: handleNewBooking.ts:242 ~ getEventTypesFromDB ~ eventTypeId:", eventTypeId);
|
||||||
const eventType = await prisma.eventType.findUniqueOrThrow({
|
const eventType = await prisma.eventType.findUniqueOrThrow({
|
||||||
where: {
|
where: {
|
||||||
id: eventTypeId,
|
id: eventTypeId,
|
||||||
|
@ -350,6 +351,7 @@ const getEventTypesFromDB = async (eventTypeId: number) => {
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
console.log("🚀 ~ file: handleNewBooking.ts:353 ~ getEventTypesFromDB ~ eventType:", eventType);
|
||||||
|
|
||||||
return {
|
return {
|
||||||
...eventType,
|
...eventType,
|
||||||
|
@ -379,7 +381,7 @@ async function ensureAvailableUsers(
|
||||||
}
|
}
|
||||||
) {
|
) {
|
||||||
const availableUsers: IsFixedAwareUser[] = [];
|
const availableUsers: IsFixedAwareUser[] = [];
|
||||||
const duration = dayjs(input.dateTo).diff(input.dateFrom, 'minute');
|
const duration = dayjs(input.dateTo).diff(input.dateFrom, "minute");
|
||||||
|
|
||||||
const originalBookingDuration = input.originalRescheduledBooking
|
const originalBookingDuration = input.originalRescheduledBooking
|
||||||
? dayjs(input.originalRescheduledBooking.endTime).diff(
|
? dayjs(input.originalRescheduledBooking.endTime).diff(
|
||||||
|
@ -658,12 +660,20 @@ async function handler(
|
||||||
identifier: userIp,
|
identifier: userIp,
|
||||||
});
|
});
|
||||||
|
|
||||||
|
console.log(
|
||||||
|
"🚀 ~ file: handleNewBooking.ts:664 ~ !req.body.eventTypeId && !!req.body.eventTypeSlug:",
|
||||||
|
process.env.DATABASE_URL
|
||||||
|
);
|
||||||
|
console.log("🚀 ~ file: handleNewBooking.ts:676 ~ prisma:", prisma);
|
||||||
|
|
||||||
// handle dynamic user
|
// handle dynamic user
|
||||||
let eventType =
|
let eventType =
|
||||||
!req.body.eventTypeId && !!req.body.eventTypeSlug
|
!req.body.eventTypeId && !!req.body.eventTypeSlug
|
||||||
? getDefaultEvent(req.body.eventTypeSlug)
|
? getDefaultEvent(req.body.eventTypeSlug)
|
||||||
: await getEventTypesFromDB(req.body.eventTypeId);
|
: await getEventTypesFromDB(req.body.eventTypeId);
|
||||||
|
|
||||||
|
console.log("🚀 ~ file: handleNewBooking.ts:663 ~ eventType:", eventType);
|
||||||
|
|
||||||
eventType = {
|
eventType = {
|
||||||
...eventType,
|
...eventType,
|
||||||
bookingFields: getBookingFieldsWithSystemFields(eventType),
|
bookingFields: getBookingFieldsWithSystemFields(eventType),
|
||||||
|
|
|
@ -0,0 +1,16 @@
|
||||||
|
# docker-compose.yml
|
||||||
|
version: '3.8'
|
||||||
|
services:
|
||||||
|
db:
|
||||||
|
image: postgres:14.1-alpine
|
||||||
|
restart: always
|
||||||
|
environment:
|
||||||
|
- POSTGRES_USER=postgres
|
||||||
|
- POSTGRES_PASSWORD=postgres
|
||||||
|
ports:
|
||||||
|
- '5432:5432'
|
||||||
|
volumes:
|
||||||
|
- db:/var/lib/postgresql/data
|
||||||
|
volumes:
|
||||||
|
db:
|
||||||
|
driver: local
|
|
@ -0,0 +1,131 @@
|
||||||
|
import { PrismaClient } from "@prisma/client";
|
||||||
|
import type { Request, Response } from "express";
|
||||||
|
import type { NextApiRequest, NextApiResponse } from "next";
|
||||||
|
import { createMocks } from "node-mocks-http";
|
||||||
|
import { test } from "vitest";
|
||||||
|
|
||||||
|
// import { default as handleNewBooking } from "@calcom/features/bookings/lib/handleNewBooking";
|
||||||
|
// import prisma from "@calcom/prisma";
|
||||||
|
import { getBooker, getDate } from "@calcom/web/test/utils/bookingScenario";
|
||||||
|
|
||||||
|
type CustomNextApiRequest = NextApiRequest & Request;
|
||||||
|
type CustomNextApiResponse = NextApiResponse & Response;
|
||||||
|
|
||||||
|
const prisma = new PrismaClient();
|
||||||
|
|
||||||
|
export function withPrisma(handler: any) {
|
||||||
|
return async (req: any, res: any) => {
|
||||||
|
if (!("prisma" in req)) {
|
||||||
|
req.prisma = prisma;
|
||||||
|
}
|
||||||
|
return handler(req, res);
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
test("handleNewBooking", async () => {
|
||||||
|
const handleNewBooking = (await import("@calcom/features/bookings/lib/handleNewBooking")).default;
|
||||||
|
const booker = getBooker({
|
||||||
|
email: "booker@example.com",
|
||||||
|
name: "Booker",
|
||||||
|
});
|
||||||
|
|
||||||
|
// const organizer = getOrganizer({
|
||||||
|
// name: "Organizer",
|
||||||
|
// email: "organizer@example.com",
|
||||||
|
// id: 101,
|
||||||
|
// schedules: [TestData.schedules.IstWorkHours],
|
||||||
|
// credentials: [getGoogleCalendarCredential()],
|
||||||
|
// selectedCalendars: [TestData.selectedCalendars.google],
|
||||||
|
// });
|
||||||
|
|
||||||
|
const pro30MinEventType = await prisma.eventType.findFirst({
|
||||||
|
where: {
|
||||||
|
slug: "30min",
|
||||||
|
hosts: {
|
||||||
|
some: {
|
||||||
|
user: {
|
||||||
|
email: "pro@example.com",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
const mockBookingData = getMockRequestDataForBooking({
|
||||||
|
data: {
|
||||||
|
eventTypeId: pro30MinEventType?.id,
|
||||||
|
responses: {
|
||||||
|
email: booker.email,
|
||||||
|
name: booker.name,
|
||||||
|
location: { optionValue: "", value: "integrations:daily" },
|
||||||
|
},
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
const { req, res } = createMocks<CustomNextApiRequest, CustomNextApiResponse>({
|
||||||
|
method: "POST",
|
||||||
|
body: mockBookingData,
|
||||||
|
prisma,
|
||||||
|
});
|
||||||
|
// console.log("🚀 ~ file: handleNewBooking.test.ts:56 ~ test ~ prisma:", prisma);
|
||||||
|
|
||||||
|
// const { req, res } = createMockNextJsRequest({
|
||||||
|
// method: "POST",
|
||||||
|
// body: mockBookingData,
|
||||||
|
// prisma,
|
||||||
|
// });
|
||||||
|
|
||||||
|
withPrisma(async (req: NextApiRequest, res: NextApiResponse) => {
|
||||||
|
// Your code here
|
||||||
|
handleNewBooking(req);
|
||||||
|
})(req, res);
|
||||||
|
|
||||||
|
// const createdBooking = await handleNewBooking(req);
|
||||||
|
// console.log("🚀 ~ file: handleNewBooking.test.ts:49 ~ test ~ createdBooking:", createdBooking);
|
||||||
|
});
|
||||||
|
|
||||||
|
function createMockNextJsRequest(...args: Parameters<typeof createMocks>) {
|
||||||
|
return createMocks<CustomNextApiRequest, CustomNextApiResponse>(...args);
|
||||||
|
}
|
||||||
|
|
||||||
|
function callWithPrisma(handler: any) {
|
||||||
|
return async (req: any, res: any) => {
|
||||||
|
if (!("prisma" in req)) {
|
||||||
|
req.prisma = prisma;
|
||||||
|
}
|
||||||
|
return handler(req, res);
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
function getBasicMockRequestDataForBooking() {
|
||||||
|
return {
|
||||||
|
start: `${getDate({ dateIncrement: 1 }).dateString}T04:00:00.000Z`,
|
||||||
|
end: `${getDate({ dateIncrement: 1 }).dateString}T04:30:00.000Z`,
|
||||||
|
eventTypeSlug: "no-confirmation",
|
||||||
|
timeZone: "Asia/Calcutta",
|
||||||
|
language: "en",
|
||||||
|
bookingUid: "bvCmP5rSquAazGSA7hz7ZP",
|
||||||
|
user: "teampro",
|
||||||
|
metadata: {},
|
||||||
|
hasHashedBookingLink: false,
|
||||||
|
hashedLink: null,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
function getMockRequestDataForBooking({
|
||||||
|
data,
|
||||||
|
}: {
|
||||||
|
data: Partial<ReturnType<typeof getBasicMockRequestDataForBooking>> & {
|
||||||
|
eventTypeId: number;
|
||||||
|
responses: {
|
||||||
|
email: string;
|
||||||
|
name: string;
|
||||||
|
location: { optionValue: ""; value: string };
|
||||||
|
};
|
||||||
|
};
|
||||||
|
}) {
|
||||||
|
return {
|
||||||
|
...getBasicMockRequestDataForBooking(),
|
||||||
|
...data,
|
||||||
|
};
|
||||||
|
}
|
|
@ -0,0 +1,22 @@
|
||||||
|
#!/usr/bin/env bash
|
||||||
|
# src/run-integration.sh
|
||||||
|
|
||||||
|
DIR="$(cd "$(dirname "$0")" && pwd)"
|
||||||
|
|
||||||
|
echo "🟡 -${DIR}"
|
||||||
|
|
||||||
|
source $DIR/setenv.sh
|
||||||
|
docker-compose -f "${DIR}/docker-compose.yml" up -d
|
||||||
|
echo '🟡 - Waiting for database to be ready...'
|
||||||
|
# DATABASE_URL="postgres://postgres:postgres@localhost:5432/postgres"
|
||||||
|
|
||||||
|
echo "🟡 -${DATABASE_URL}"
|
||||||
|
|
||||||
|
# $DIR/wait-for-it.sh "${DATABASE_URL}" -t 60 -- echo '🟢 - Database is ready!'
|
||||||
|
yarn prisma migrate dev
|
||||||
|
yarn prisma db seed
|
||||||
|
yarn prisma generate
|
||||||
|
|
||||||
|
echo ${DIR}/handleNewbooking.test.ts
|
||||||
|
|
||||||
|
yarn vitest "${DIR}"
|
|
@ -0,0 +1,6 @@
|
||||||
|
#!/usr/bin/env bash
|
||||||
|
# scripts/setenv.sh
|
||||||
|
|
||||||
|
# Export env vars
|
||||||
|
export $(grep -v '^#' .env | xargs)
|
||||||
|
export DATABASE_URL="postgres://postgres:postgres@localhost:5432/postgres"
|
|
@ -0,0 +1,182 @@
|
||||||
|
#!/usr/bin/env bash
|
||||||
|
# Use this script to test if a given TCP host/port are available
|
||||||
|
|
||||||
|
WAITFORIT_cmdname=${0##*/}
|
||||||
|
|
||||||
|
echoerr() { if [[ $WAITFORIT_QUIET -ne 1 ]]; then echo "$@" 1>&2; fi }
|
||||||
|
|
||||||
|
usage()
|
||||||
|
{
|
||||||
|
cat << USAGE >&2
|
||||||
|
Usage:
|
||||||
|
$WAITFORIT_cmdname host:port [-s] [-t timeout] [-- command args]
|
||||||
|
-h HOST | --host=HOST Host or IP under test
|
||||||
|
-p PORT | --port=PORT TCP port under test
|
||||||
|
Alternatively, you specify the host and port as host:port
|
||||||
|
-s | --strict Only execute subcommand if the test succeeds
|
||||||
|
-q | --quiet Don't output any status messages
|
||||||
|
-t TIMEOUT | --timeout=TIMEOUT
|
||||||
|
Timeout in seconds, zero for no timeout
|
||||||
|
-- COMMAND ARGS Execute command with args after the test finishes
|
||||||
|
USAGE
|
||||||
|
exit 1
|
||||||
|
}
|
||||||
|
|
||||||
|
wait_for()
|
||||||
|
{
|
||||||
|
if [[ $WAITFORIT_TIMEOUT -gt 0 ]]; then
|
||||||
|
echoerr "$WAITFORIT_cmdname: waiting $WAITFORIT_TIMEOUT seconds for $WAITFORIT_HOST:$WAITFORIT_PORT"
|
||||||
|
else
|
||||||
|
echoerr "$WAITFORIT_cmdname: waiting for $WAITFORIT_HOST:$WAITFORIT_PORT without a timeout"
|
||||||
|
fi
|
||||||
|
WAITFORIT_start_ts=$(date +%s)
|
||||||
|
while :
|
||||||
|
do
|
||||||
|
if [[ $WAITFORIT_ISBUSY -eq 1 ]]; then
|
||||||
|
nc -z $WAITFORIT_HOST $WAITFORIT_PORT
|
||||||
|
WAITFORIT_result=$?
|
||||||
|
else
|
||||||
|
(echo -n > /dev/tcp/$WAITFORIT_HOST/$WAITFORIT_PORT) >/dev/null 2>&1
|
||||||
|
WAITFORIT_result=$?
|
||||||
|
fi
|
||||||
|
if [[ $WAITFORIT_result -eq 0 ]]; then
|
||||||
|
WAITFORIT_end_ts=$(date +%s)
|
||||||
|
echoerr "$WAITFORIT_cmdname: $WAITFORIT_HOST:$WAITFORIT_PORT is available after $((WAITFORIT_end_ts - WAITFORIT_start_ts)) seconds"
|
||||||
|
break
|
||||||
|
fi
|
||||||
|
sleep 1
|
||||||
|
done
|
||||||
|
return $WAITFORIT_result
|
||||||
|
}
|
||||||
|
|
||||||
|
wait_for_wrapper()
|
||||||
|
{
|
||||||
|
# In order to support SIGINT during timeout: http://unix.stackexchange.com/a/57692
|
||||||
|
if [[ $WAITFORIT_QUIET -eq 1 ]]; then
|
||||||
|
timeout $WAITFORIT_BUSYTIMEFLAG $WAITFORIT_TIMEOUT $0 --quiet --child --host=$WAITFORIT_HOST --port=$WAITFORIT_PORT --timeout=$WAITFORIT_TIMEOUT &
|
||||||
|
else
|
||||||
|
timeout $WAITFORIT_BUSYTIMEFLAG $WAITFORIT_TIMEOUT $0 --child --host=$WAITFORIT_HOST --port=$WAITFORIT_PORT --timeout=$WAITFORIT_TIMEOUT &
|
||||||
|
fi
|
||||||
|
WAITFORIT_PID=$!
|
||||||
|
trap "kill -INT -$WAITFORIT_PID" INT
|
||||||
|
wait $WAITFORIT_PID
|
||||||
|
WAITFORIT_RESULT=$?
|
||||||
|
if [[ $WAITFORIT_RESULT -ne 0 ]]; then
|
||||||
|
echoerr "$WAITFORIT_cmdname: timeout occurred after waiting $WAITFORIT_TIMEOUT seconds for $WAITFORIT_HOST:$WAITFORIT_PORT"
|
||||||
|
fi
|
||||||
|
return $WAITFORIT_RESULT
|
||||||
|
}
|
||||||
|
|
||||||
|
# process arguments
|
||||||
|
while [[ $# -gt 0 ]]
|
||||||
|
do
|
||||||
|
case "$1" in
|
||||||
|
*:* )
|
||||||
|
WAITFORIT_hostport=(${1//:/ })
|
||||||
|
WAITFORIT_HOST=${WAITFORIT_hostport[0]}
|
||||||
|
WAITFORIT_PORT=${WAITFORIT_hostport[1]}
|
||||||
|
shift 1
|
||||||
|
;;
|
||||||
|
--child)
|
||||||
|
WAITFORIT_CHILD=1
|
||||||
|
shift 1
|
||||||
|
;;
|
||||||
|
-q | --quiet)
|
||||||
|
WAITFORIT_QUIET=1
|
||||||
|
shift 1
|
||||||
|
;;
|
||||||
|
-s | --strict)
|
||||||
|
WAITFORIT_STRICT=1
|
||||||
|
shift 1
|
||||||
|
;;
|
||||||
|
-h)
|
||||||
|
WAITFORIT_HOST="$2"
|
||||||
|
if [[ $WAITFORIT_HOST == "" ]]; then break; fi
|
||||||
|
shift 2
|
||||||
|
;;
|
||||||
|
--host=*)
|
||||||
|
WAITFORIT_HOST="${1#*=}"
|
||||||
|
shift 1
|
||||||
|
;;
|
||||||
|
-p)
|
||||||
|
WAITFORIT_PORT="$2"
|
||||||
|
if [[ $WAITFORIT_PORT == "" ]]; then break; fi
|
||||||
|
shift 2
|
||||||
|
;;
|
||||||
|
--port=*)
|
||||||
|
WAITFORIT_PORT="${1#*=}"
|
||||||
|
shift 1
|
||||||
|
;;
|
||||||
|
-t)
|
||||||
|
WAITFORIT_TIMEOUT="$2"
|
||||||
|
if [[ $WAITFORIT_TIMEOUT == "" ]]; then break; fi
|
||||||
|
shift 2
|
||||||
|
;;
|
||||||
|
--timeout=*)
|
||||||
|
WAITFORIT_TIMEOUT="${1#*=}"
|
||||||
|
shift 1
|
||||||
|
;;
|
||||||
|
--)
|
||||||
|
shift
|
||||||
|
WAITFORIT_CLI=("$@")
|
||||||
|
break
|
||||||
|
;;
|
||||||
|
--help)
|
||||||
|
usage
|
||||||
|
;;
|
||||||
|
*)
|
||||||
|
echoerr "Unknown argument: $1"
|
||||||
|
usage
|
||||||
|
;;
|
||||||
|
esac
|
||||||
|
done
|
||||||
|
|
||||||
|
if [[ "$WAITFORIT_HOST" == "" || "$WAITFORIT_PORT" == "" ]]; then
|
||||||
|
echoerr "Error: you need to provide a host and port to test."
|
||||||
|
usage
|
||||||
|
fi
|
||||||
|
|
||||||
|
WAITFORIT_TIMEOUT=${WAITFORIT_TIMEOUT:-15}
|
||||||
|
WAITFORIT_STRICT=${WAITFORIT_STRICT:-0}
|
||||||
|
WAITFORIT_CHILD=${WAITFORIT_CHILD:-0}
|
||||||
|
WAITFORIT_QUIET=${WAITFORIT_QUIET:-0}
|
||||||
|
|
||||||
|
# Check to see if timeout is from busybox?
|
||||||
|
WAITFORIT_TIMEOUT_PATH=$(type -p timeout)
|
||||||
|
WAITFORIT_TIMEOUT_PATH=$(realpath $WAITFORIT_TIMEOUT_PATH 2>/dev/null || readlink -f $WAITFORIT_TIMEOUT_PATH)
|
||||||
|
|
||||||
|
WAITFORIT_BUSYTIMEFLAG=""
|
||||||
|
if [[ $WAITFORIT_TIMEOUT_PATH =~ "busybox" ]]; then
|
||||||
|
WAITFORIT_ISBUSY=1
|
||||||
|
# Check if busybox timeout uses -t flag
|
||||||
|
# (recent Alpine versions don't support -t anymore)
|
||||||
|
if timeout &>/dev/stdout | grep -q -e '-t '; then
|
||||||
|
WAITFORIT_BUSYTIMEFLAG="-t"
|
||||||
|
fi
|
||||||
|
else
|
||||||
|
WAITFORIT_ISBUSY=0
|
||||||
|
fi
|
||||||
|
|
||||||
|
if [[ $WAITFORIT_CHILD -gt 0 ]]; then
|
||||||
|
wait_for
|
||||||
|
WAITFORIT_RESULT=$?
|
||||||
|
exit $WAITFORIT_RESULT
|
||||||
|
else
|
||||||
|
if [[ $WAITFORIT_TIMEOUT -gt 0 ]]; then
|
||||||
|
wait_for_wrapper
|
||||||
|
WAITFORIT_RESULT=$?
|
||||||
|
else
|
||||||
|
wait_for
|
||||||
|
WAITFORIT_RESULT=$?
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
if [[ $WAITFORIT_CLI != "" ]]; then
|
||||||
|
if [[ $WAITFORIT_RESULT -ne 0 && $WAITFORIT_STRICT -eq 1 ]]; then
|
||||||
|
echoerr "$WAITFORIT_cmdname: strict mode, refusing to execute subprocess"
|
||||||
|
exit $WAITFORIT_RESULT
|
||||||
|
fi
|
||||||
|
exec "${WAITFORIT_CLI[@]}"
|
||||||
|
else
|
||||||
|
exit $WAITFORIT_RESULT
|
||||||
|
fi
|
|
@ -107,6 +107,13 @@ export async function createUserAndEventType({
|
||||||
data: eventTypeData,
|
data: eventTypeData,
|
||||||
});
|
});
|
||||||
|
|
||||||
|
await prisma.host.create({
|
||||||
|
data: {
|
||||||
|
userId: theUser.id,
|
||||||
|
eventTypeId: id,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
console.log(
|
console.log(
|
||||||
`\t📆 Event type ${eventTypeData.slug} with id ${id}, length ${eventTypeData.length}min - ${process.env.NEXT_PUBLIC_WEBAPP_URL}/${user.username}/${eventTypeData.slug}`
|
`\t📆 Event type ${eventTypeData.slug} with id ${id}, length ${eventTypeData.length}min - ${process.env.NEXT_PUBLIC_WEBAPP_URL}/${user.username}/${eventTypeData.slug}`
|
||||||
);
|
);
|
||||||
|
|
Loading…
Reference in New Issue
Block a user