А вот неромантичный вопрос. Есть play приложение, есть эндпойнт с multipart боди парсером. С фронта шлются картинки (пачкой, на input стоит multi). Нужно к каждой сделать thumbnail и загрузить все это на S3. Как загрузятся, начинается всякая еще более скучная бизнес логика. Вопрос такой — то как play предлагает в своих доках (TemporaryFile, потом создаешь файл, moveTo, потом загружаешь все это, еще пару файлов создав для процессинга) это самый адекватный вариант? Не кидайте в меня тяжелыми предметами. Я пришел из node.js... там бы это был стрим. Я не говорю что там лучше, или хуже, я хочу понять как принятно в скале:-)

ты такой берёшь стрим, а потом мэпасинк, буффер, все дела

Oleg сорян, но ты уже выложил презенташку ?

Раньше определение проекта было определено через глобальный скоуп, теперь потребовалось через project in file(".") создавать, как правильно settings задать , чтобы PB.targets in Compile := Seq( scalapb.gen() -> (sourceManaged in Compile).value ) вновь заработало?

Oleg сорян, но ты уже выложил презенташку ?

да

да

А скинь в лс ссылку если не сложно

у тебя там в конце ошибка. пиши в скалачате правильно - "... как приятно в скале"

?

Раньше определение проекта было определено через глобальный скоуп, теперь потребовалось через project in file(".") создавать, как правильно settings задать , чтобы PB.targets in Compile := Seq( scalapb.gen() -> (sourceManaged in Compile).value ) вновь заработало?

Чёт знакомое, протобафку делаешь?)

Чёт знакомое, протобафку делаешь?)

Да, но оно не собирается теперь ,если sbt compile делаешь

Да, но оно не собирается теперь ,если sbt compile делаешь

Какая версия

pre4 ?

sbt.version = 0.13.15

или тебе какую?

Scalapb

libraryDependencies += "com.trueaccord.scalapb" %% "compilerplugin" % "0.6.0-pre5"

Ща обновлю у себя и гляну

в Play это стрим

В play я так понимаю это Iteratees, самое близкое что я нашел...

Iteratees заменили уже на akka streams

в 2.6?

iteratees выпилены

в 2.6?

в 2.5

в 2.6?

https://www.playframework.com/documentation/2.5.x/StreamsMigration25

Найс. Буду читать! Спасибо огромное

libraryDependencies += "com.trueaccord.scalapb" %% "compilerplugin" % "0.6.0-pre5"

а когда кстати релиз был?

а когда кстати релиз был?

не знаю, я просто зашёл на сайт и взял посленюю версию, но как заставить работать ее из lazy val root = (project in file(".")).settings( Seq( ... , PB.targets in Complie := Seq( scalapb.gen() -> (sourceManaged in Compile).value )) не понял

да

А где?

тут https://anaconda.org/Odomontois/scalameetup/notebook

тут https://anaconda.org/Odomontois/scalameetup/notebook

как себе в navigator это поставить?

А вот еще глупый вопрос. Вся романтика стримов была убита прозой java aws sdk. Им для multipart нужно чтобы куски были по 5мб... А как еще к нему стрим прикрутить я не очень понимаю. Плюс библиотека для обработки картинок тоже не особо расположена к стримам. Если только я не упустил какую нибудь магическую связь между java InputStream и акковскими стримами. Я помозговал еще, потыкался. Скажите, пожалуйста, а очень тупо файлы в байт аррэи читать и ими оперировать? А то если с файлами работать — сначала TemporaryFile пренеси в обычный файл, а то он его удалит (в какой-то непонятный момент). Потом создай файл для того чтобы либе картиночной было куда писать результат. А потом уже пошли его в s3. А так я могу взять TemporaryFile, сделать ему readAllBytes, применить трансформации которые мне вернут опять же байты, потом сконструировать ByteArrayInputStream и отдать клиенту s3

Альпака коннекторы к акка стримам не подходят?

я в альпаку даже не смотрел:)

http://doc.akka.io/docs/akka/current/scala/stream/stream-io.html#streaming-file-io вот тут внизу описано как файлы читать в akka streams

Я правильно понимаю что с байт аррэями плохая идея?:-)

Стримы гляну, спасибо!

С байт арреями идея нормальная, если у тебя никто в сервис файлы по 3 гига пихать не планирует.

А так - можно либо все приседания с файлом делать внутри стримов, а потом его материализовать в OutputStream: http://doc.akka.io/japi/akka-stream-and-http-experimental/2.0/akka/stream/javadsl/StreamConverters$.html

Либо брать s3 клиент из альпакки, который умеет прям стрим заливать

Кстати, если пихать материализованный OutputStream в aws-s3-sdk, то его надо буферизовать, а то он по одному байту будет заливать

А клиент из альпакки глючный и кривой. Есть два стула, классика.

а чем alpakka s3 глючная? Пока заюзали для стрим даунлода, работает.

Из того, что я видел - https://github.com/akka/alpakka/issues/348

И ещё https://github.com/akka/alpakka/issues/316

Но так то жить можно, да.

похоже в мастере уже пофиксили, судя по коммитам в ишью

Не юзайте aws вот и все)

Не юзайте aws вот и все)

советчик

Не юзайте программирование, вот и всё

Постоянные баги же

не слушайте советы!

Не юзайте программирование, вот и всё

А это мысль

все баги от разработчиков, следовательно, не будет разработчиков - не будет багов

аминь

все баги от разработчиков, следовательно, не будет разработчиков - не будет багов

от тестеров и пользователей же

от тестеров и пользователей же

Увеличиваем выборку, от людей

Этот момент, когда ты настолько довел идею, что она больше ничего не компилирует, и просто виснет на любую попытку компиляции %)

Но от трех до пяти перезпусков идеи и clean'ов проекта спасут

Этот момент, когда ты настолько довел идею, что она больше ничего не компилирует, и просто виснет на любую попытку компиляции %)

включай use SBT

не, я из идеи тесты запускаю, люблю очень их менюшку про тесты

а с use sbt там сбтшный вывод просто

нет, тесты так же запустятся

просто компилиться будет в SBT

хм, с релизом 2017.1 пробовал. Значит надо еще раз попробовать :)

просто компилиться будет в SBT

оно стало почти юзабельным

Кто-то запилил кучу js оберток - https://github.com/DefinitelyScala

Кто-то запилил кучу js оберток - https://github.com/DefinitelyScala

Они же просто сгенерированы из TypeScript дефинишнов

вполне возможно, что бОльшая часть из них просто не будут работать так, как нужно

Ну зато подойдёт как норм репо-хаб, куда люди, которые сделают-таки нормальные обёртки запулреквестят своё

типа webjars следующего поколения

https://github.com/DefinitelyScala/scala-js-long Лол, даже для либы, которая добавляет в жс лонги, сделали фасад.

вопрос по акка персистанс, у меня есть актор встречи и актор который находится над всеми встречами чтобы роутить команду куда надо и делать валидации типо "встреча должна иметь уникальное имя". У меня есть два варианта работы с менеджером встречь, первый это создавать акторы встречь во время проигрывания событий или делать это on demand. Какой вариант предпочтительней? Насколько долго подымается персистанс актор в случае если в нем до 100 ивентов?

несущественно быстро

по идее я могу себе позволить подымать актор только когда он реально будет нужен? и это будет адекватный респонз тайм до 200-300 миллисекунд

100 ивентов вычитывается за один батч в кассандре, и очень быстро сворачивается в нужный стейт

да

да

спасибо

но как всегда ответ - лучше сделать замеры

само собой, просто я никогда такого не делал и спрашиваю делают ли так впринципе

А твой менеджер тоже персистентный?

да

мне надо знать имена встречь для валидации

То есть при создании встречи ты будешь 1. Записывать имя в менеджер 2. Создавать саму встречу ?

сеичас при создании я планирую сохранить событие о том что встреча была создана (на основе этого события строить сет имен встреч) а потом по нужде подымать актор

Просто учти что ты делаешь два изменения за один запрос и они могут зафейлиться, то есть может быть состояние что в менеджере встреча есть а вот сохранить ивент создания самой встречи не получилось (сеть глюкнула)

аа

так ок

то есть кеш имен будет eventual consistent?

вроде нет же, актор не будет процессить новые команды пока не зарековерит старые ивенты

и дальше по порядку все

в менеджмент акторе будет хранится стейт всех данных для валидации на создание встречи

и он будет всегда актуален так как строится на основе событие ВстречаСоздана

А кто в итоге владелец события ВстречаСоздана? Встреча или Менеджер?

менеджер

сама встреча знает о том что создана потому-что актор был создан

может не очень круто получиться, ибо пока у тебя этот менеджер будет занят записями встреч, запросы на созданные проксироваться не будут

А параметры создания ей не нужны?