Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
import { LocalQuery } from "../models/Commands";
import { Firestore } from "@google-cloud/firestore";
const grpc = require("@grpc/grpc-js");
// Create a new client
const firestore = new Firestore({
servicePath: "localhost",
port: 8080,
projectId: "firebase-explorer-test",
sslCreds: grpc.credentials.createInsecure(),
customHeaders: {
Authorization: "Bearer owner"
}
});
export const handleLocalQuery = async (query: LocalQuery) => {
let data: { [key: string]: any } = {};
const db = firestore;
const result = await db.doc("movies/60756").get();
const collections = await result.ref.listCollections();
console.log(collections);
data["success"] = true;
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
'use strict';
// [START bookshelf_firestore_client]
const {Firestore} = require('@google-cloud/firestore');
const db = new Firestore();
const collection = 'Book';
// [END bookshelf_firestore_client]
// Lists all books in the database sorted alphabetically by title.
async function list(limit, token) {
const snapshot = await db
.collection(collection)
.orderBy('title')
.startAfter(token || '')
.limit(limit)
.get();
if (snapshot.empty) {
return {
books: [],
const queueParts = Config.get('serviceNotificationQueueUrl').split('/');
const queueName = queueParts[queueParts.length - 1];
const sqs = new SQS();
const queues = await sqs.listQueues().promise();
if (!queues.QueueUrls || !queues.QueueUrls.includes(queueName)) {
await sqs
.createQueue({
QueueName: queueName
})
.promise();
}
// Utilize the local firestore emulator if we were told to use it
if (firestoreEnabled && NODE_ENV === 'development') {
const fstore = new Firestore({
customHeaders: {
Authorization: 'Bearer owner'
},
port: 8006,
projectId: 'fx-event-broker',
servicePath: 'localhost',
sslCreds: grpc.credentials.createInsecure()
});
db = new FirestoreDatastore(firestoreConfig, fstore);
}
} catch (err) {
logger.error('Error loading application:', { err });
process.exit(1);
}
const capabilityService = new ClientCapabilityService(
proxyWritableMethods(dryrun, stats);
if (!storageBucket && projectId) {
storageBucket = `${projectId}.appspot.com`;
}
const providedApp = app;
if (!app) {
app = admin.initializeApp({
projectId,
storageBucket
});
}
// Use Firestore directly so we can mock for dryruns
const firestore = new Firestore({projectId});
const collection = firestore.collection('fireway');
// Get the latest migration
const result = await collection
.orderBy('installed_rank', 'desc')
.limit(1)
.get();
const [latestDoc] = result.docs;
const latest = latestDoc && latestDoc.data();
if (latest && !latest.success) {
throw new Error(`Migration to version ${latest.version} using ${latest.script} failed! Please restore backups and roll back database and code!`);
}
let installed_rank;
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
'use strict';
// [START firestore_quickstart]
const {Firestore} = require('@google-cloud/firestore');
// Create a new client
const firestore = new Firestore();
async function quickstart() {
// Obtain a document reference.
const document = firestore.doc('posts/intro-to-firestore');
// Enter new data into the document.
await document.set({
title: 'Welcome to Firestore',
body: 'Hello World',
});
console.log('Entered new data into the document');
// Update an existing document.
await document.update({
body: 'My first Firestore app',
});
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
const {Firestore} = require('@google-cloud/firestore');
const express = require('express');
const session = require('express-session');
const app = express();
const {FirestoreStore} = require('@google-cloud/connect-firestore');
app.use(
session({
store: new FirestoreStore({
dataset: new Firestore({
kind: 'express-sessions',
}),
}),
secret: 'my-secret',
resave: false,
saveUninitialized: true,
})
);
const greetings = [
'Hello World',
'Hallo Welt',
'Ciao Mondo',
'Salut le Monde',
'Hola Mundo',
];
constructor(config: FirestoreDbSettings, firestore?: Firestore) {
this.prefix = config.prefix;
if (firestore) {
this.db = firestore;
} else {
// keyFilename takes precedence over credentials
if (config.keyFilename) {
delete config.credentials;
}
this.db = new Firestore(config);
}
}
const { Firestore } = require('@google-cloud/firestore')
const firestore = new Firestore({
projectId: process.env.FIREBASE_PROJECT_ID,
credentials: {
client_email: process.env.FIREBASE_CLIENT_EMAIL,
private_key: process.env.FIREBASE_PRIVATE_KEY.replace(/\\n/g, '\n'),
},
})
const guild = require('./guild')(firestore)
const overall = require('./overall')(firestore)
const memoedOffenderUserIds = new Set()
firestore
.collection('users')
.get()
.then(snapshot => {
console.log(snapshot.size, 'offenders found in database.')
snapshot.forEach(el => memoedOffenderUserIds.add(el.id))
function initialize(options) {
firestore = new FirebaseFirestore.Firestore(options);
}
Pring.initialize = initialize;
const {Firestore} = require('@google-cloud/firestore');
import user from '../models/user';
const firestore = new Firestore();
const collection = firestore.collection('users');
class repository {
delete(id: any): void {
collection.doc(id).delete();
}
async update(id: string, username: string, password: string): Promise {
var docRef = collection.dc(id);
var updateObject = await user.create(username, password);
var data = { 'username': updateObject.username, 'password': updateObject.hashedPassword };
docRef.update(data);
return await this.get(id);
}