fix subscription

This commit is contained in:
2023-09-20 23:06:39 +02:00
parent dabadaa1c9
commit 80fdc45174
2 changed files with 5 additions and 9 deletions

View File

@@ -21,7 +21,7 @@ watch(() => trackedItemStore.items.value, async itms => {
return { ...i, ...price };
});
})
}, { immediate: true })
</script>

View File

@@ -1,16 +1,12 @@
import { usePocketBase } from "@/pocketbase";
import { RecordModel, RecordSubscription, UnsubscribeFunc } from "pocketbase";
import { Ref, computed, onMounted, onUnmounted, ref } from "vue";
import { RecordModel, RecordSubscription } from "pocketbase";
import { Ref, computed, onMounted, ref } from "vue";
export const watchCollection = <T extends RecordModel = RecordModel>(collection: string, query: string, callback: (data: RecordSubscription<T>) => void) => {
export const watchCollection = <T extends RecordModel = RecordModel>(collection: string, topic: string, callback: (data: RecordSubscription<T>) => void) => {
const pb = usePocketBase();
let unsubscribe: UnsubscribeFunc = () => Promise.resolve();
onMounted(async () => {
unsubscribe = await pb.collection(collection).subscribe<T>(query, callback);
});
onUnmounted(() => unsubscribe());
onMounted(async () => await pb.collection(collection).subscribe<T>(topic, callback));
};
export const useCollection = <T extends RecordModel = RecordModel>(collection: string) => {