class NegociacaoController {
constructor() {
let $ = document.querySelector.bind(document);
this._inputData = $('#data');
this._inputQuantidade = $('#quantidade');
this._inputValor = $('#valor');
this._listaNegociacoes = new Bind(
new ListaNegociacoes(),
new NegociacoesView($('#negociacoesView')),
'adiciona', 'esvazia' , 'ordena', 'inverteOrdem');
this._mensagem = new Bind(
new Mensagem(), new MensagemView($('#mensagemView')),
'texto');
this._ordemAtual = '';
ConnectionFactory
.getConnection()
.then(connection => new NegociacaoDao(connection))
.then(dao => dao.listaTodos())
.then(negociacoes =>
negociacoes.forEach(negociacao =>
this._listaNegociacoes.adiciona(negociacao)))
.catch(erro => {
console.log(erro);
this._mensagem.texto = erro;
});
}
adiciona(event) {
event.preventDefault();
ConnectionFactory
.getConnection()
.then(connection => {
let negociacao = this._criaNegociacao();
new NegociacaoDao(connection)
.adiciona(negociacao)
.then(() => {
this._listaNegociacoes.adiciona(negociacao);
this._mensagem.texto = 'Negociação adicionada com sucesso';
this._limpaFormulario();
})
})
.catch(erro => this._mensagem.texto = erro);
}
importaNegociacoes() {
let service = new NegociacaoService();
service
.obterNegociacoes()
.then(negociacoes => negociacoes.forEach(negociacao => {
this._listaNegociacoes.adiciona(negociacao);
this._mensagem.texto = 'Negociações do período importadas'
}))
.catch(erro => this._mensagem.texto = erro);
}
apaga() {
ConnectionFactory
.getConnection()
.then(connection => new NegociacaoDao(connection))
.then(dao => dao.apagaTodos())
.then(mensagem => {
this._mensagem.texto = mensagem;
this._listaNegociacoes.esvazia();
});
}
class NegociacaoDao {
constructor(connection) {
this._connection = connection;
this._store = 'negociacoes';
}
adiciona(negociacao) {
return new Promise((resolve, reject) => {
let request = this._connection
.transaction([this._store],"readwrite")
.objectStore(this._store)
.add(negociacao)
request.onsuccess = e => {
resolve();
};
request.onerror = e => {
console.log(e.target.error);
reject('Não foi possível adicionar a negociação');
};
});
}
listaTodos() {
return new Promise((resolve, reject) => {
let cursor = this._connection
.transaction([this._store], 'readwrite')
.objectStore(this._store)
.openCursor();
let negociacoes = [];
cursor.onsuccess = e => {
let atual = e.target.result;
if(atual) {
let dado = atual.value;
negociacoes.push(new Negociacao(dado._data, dado._quantidade, dado._valor));
atual.continue();
} else {
resolve(negociacoes);
}
};
cursor.onerror = e => {
console.log(e.target.error);
reject('Não foi possível listar as negociações');
};
});
}
apagaTodos() {
return new Promise((resolve, reject) => {
let request = this._connection
.transaction([this._store], 'readwrite')
.objectStore(this._store)
.clear();
request.onsuccess = e => resolve('Negociações apagadas com sucesso');
request.onerror = e => {
console.log(e.target.error);
reject('Não foi possível apagar as negociações');
};
});
}
}
mensagem de erro no console do navegador : Uncaught (in promise) DOMException: Failed to execute 'add' on 'IDBObjectStore': The object store uses out-of-line keys and has no key generator and the key parameter was not provided.