Облачная функция Firebase onWrite запускает несколько раз

Question

Я создаю контактную форму на своем веб-сайте, которая пишет в базу данных в реальном времени. Используя Облачные функции, я хочу ответить на запись в базе данных, отправив себе электронное письмо с этими контактными данными.

Я подтвердил, что отправляю полезные данные только один раз, и данные записываются в базу данных совершенно нормально. У меня проблема в том, что onWrite отвечает на каждую строку ввода в базу данных, например, я посылаю имя, адрес электронной почты, компанию и сообщение, поэтому моя функция вызывается 4 раза. Я НЕ перезаписываю базу данных, которая, как я знаю, выполняет другой вызов. Строка данных принимается при каждом вызове как отдельные значения, я не получаю объект со всеми значениями, как "обещано" в документации. Я также пытался создать, который даже не вызывался.

Я дезинформирован? Это ожидаемое поведение? Любая помощь приветствуется.

Код...

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp(functions.config().firebase);

exports.sendContactMessage = functions.database
  .ref('/messages/{pushKey}')
  .onWrite(event => {
    const snapshot = event.data;
    // Only send email for new messages.
    if (!snapshot.exists()) { return null; }

    const val = snapshot.val();

    console.log(val);
  });

Мой класс, который публикует сообщения

import { Component } from '@angular/core';
import { FormBuilder, FormGroup, Validators } from '@angular/forms';
import { AngularFireDatabase, AngularFireObject } from 'angularfire2/database';
import * as firebase from 'firebase/app';

export interface Item { name: string; email: string; message: string; html: string; date: string }

@Component({
  selector: 'app-contact',
  templateUrl: './contact.component.html',
  styleUrls: ['./contact.component.scss']
})
export class ContactComponent {
      public rForm: FormGroup;
      public post: any;
      public message: string = '';
      public name: string = '';
      public company: string = '';
      public email: string = '';
      itemRef: AngularFireObject<any[]>;
      item;

  constructor(private fb: FormBuilder, public db: AngularFireDatabase) {
    this.createForm();
    this.itemRef = db.object('messages');
    this.item = this.itemRef.valueChanges();
  }

  createForm() {
    this.rForm = this.fb.group({
      name: [null, Validators.required],
      email: [null, Validators.compose([Validators.required, Validators.email])],
      message: [null, Validators.compose([Validators.required, Validators.minLength(15)])],
      validate: ''
    });
  }

  sendMessage(post) {

    this.name = post.name;
    this.email = post.email;
    this.message = post.message;

    const item: Item = {
      name: post.name,
      email: post.email,
      message: post.message,
      html: `You were contacted from your website by ${post.name}. They said "${post.message}". You can contact them back on ${post.email}`,
      date: Date()
    };

    this.itemRef.update(item);
  }
}

Answer 1

Я сомневаюсь, что кто-то так же глуп, как я, но я писал в то же место в моей БД. 1 запись существовала только когда-либо, поэтому я "менял" 4 элемента данных, поэтому я вызывал 4 события onWrite.

Я решил эту проблему, создав новую запись в базе данных в уникальной папке.