move all into clusters

This commit is contained in:
salam committed 2026-03-04 19:07:33 +01:00
1 parent 7ff3fbadb6
commit a980ea92ce
91 files changed
+300 -262

No files matched your search

@@ -0,0 +1,11 @@
<?php
namespace App\Filament\Clusters\Grapper\Resources\Supervisors\Pages;
use App\Filament\Clusters\Grapper\Resources\Supervisors\SupervisorResource;
use Filament\Resources\Pages\CreateRecord;
class CreateSupervisor extends CreateRecord
{
protected static string $resource = SupervisorResource::class;
}
@@ -0,0 +1,19 @@
<?php
namespace App\Filament\Clusters\Grapper\Resources\Supervisors\Pages;
use App\Filament\Clusters\Grapper\Resources\Supervisors\SupervisorResource;
use Filament\Actions\DeleteAction;
use Filament\Resources\Pages\EditRecord;
class EditSupervisor extends EditRecord
{
protected static string $resource = SupervisorResource::class;
protected function getHeaderActions(): array
{
return [
DeleteAction::make(),
];
}
}
@@ -0,0 +1,27 @@
<?php
namespace App\Filament\Clusters\Grapper\Resources\Supervisors\Pages;
use App\Actions\SupervisorStatus;
use App\Filament\Clusters\Grapper\Resources\Supervisors\SupervisorResource;
use Filament\Actions\Action;
use Filament\Actions\CreateAction;
use Filament\Resources\Pages\ListRecords;
class ListSupervisors extends ListRecords
{
protected static string $resource = SupervisorResource::class;
protected function getHeaderActions(): array
{
return [
CreateAction::make()->label('New')->icon('phosphor-plus'),
Action::make('stop_all')->icon('phosphor-prohibit')->action(function (): void {
SupervisorStatus::set(0);
}),
Action::make('start_all')->icon('phosphor-play')->action(function (): void {
SupervisorStatus::set(1);
}),
];
}
}
@@ -0,0 +1,32 @@
<?php
namespace App\Filament\Clusters\Grapper\Resources\Supervisors\Schemas;
use Filament\Forms\Components\Select;
use Filament\Schemas\Schema;
class SupervisorForm
{
public static function configure(Schema $schema): Schema
{
return $schema
->components([
Select::make('provider_id')
->relationship('provider', 'name')
->required()
->preload(),
Select::make('sport_id')
->relationship('sport', 'name')
->nullable(),
// TextInput::make('sleep')->default(30),
// TextInput::make('maxsconds')->label('Seconds till throwing an error')->default(1800),
// Section::make('Run processes paralell for speed')
// ->description('Set start and end days if more processes grap the same data')
// ->schema([
// TextInput::make('days_from')->columns(1)->default(0),
// TextInput::make('days_to')->columns(1)->default(1),
// ])->columns(2)->columnSpanFull(),
]);
}
}
@@ -0,0 +1,47 @@
<?php
namespace App\Filament\Clusters\Grapper\Resources\Supervisors;
use App\Filament\Clusters\Grapper\GrapperCluster;
use App\Filament\Clusters\Grapper\Resources\Supervisors\Pages\ListSupervisors;
use App\Filament\Clusters\Grapper\Resources\Supervisors\Tables\SupervisorsTable;
use App\Filament\Resources\Supervisors\Schemas\SupervisorForm;
use App\Models\Supervisor;
use Filament\Resources\Resource;
use Filament\Schemas\Schema;
use Filament\Tables\Table;
class SupervisorResource extends Resource
{
protected static ?string $model = Supervisor::class;
protected static string|\BackedEnum|null $navigationIcon = 'phosphor-network';
protected static ?string $cluster = GrapperCluster::class;
protected static ?int $navigationSort = 1;
protected static string|\UnitEnum|null $navigationGroup = 'Grapper';
public static function form(Schema $schema): Schema
{
return SupervisorForm::configure($schema);
}
public static function table(Table $table): Table
{
return SupervisorsTable::configure($table);
}
public static function getPages(): array
{
return [
'index' => ListSupervisors::route('/'),
];
}
public static function getNavigationBadge(): ?string
{
return parent::getEloquentQuery()->count();
}
}
@@ -0,0 +1,242 @@
<?php
namespace App\Filament\Clusters\Grapper\Resources\Supervisors\Tables;
use App\Filament\Clusters\Grapper\Resources\Supervisors\Pages\ListSupervisors;
use App\Models\Sport;
use App\Models\Supervisor;
use App\Models\TxoddsMarket;
use Filament\Actions\BulkAction;
use Filament\Actions\BulkActionGroup;
use Filament\Actions\DeleteAction;
use Filament\Actions\DeleteBulkAction;
use Filament\Actions\EditAction;
use Filament\Forms\Components\TextInput;
use Filament\Tables\Columns\Layout\Split;
use Filament\Tables\Columns\Layout\Stack;
use Filament\Tables\Columns\SelectColumn;
use Filament\Tables\Columns\TextColumn;
use Filament\Tables\Columns\TextInputColumn;
use Filament\Tables\Columns\ToggleColumn;
use Filament\Tables\Enums\FiltersLayout;
use Filament\Tables\Filters\SelectFilter;
use Filament\Tables\Filters\TernaryFilter;
use Filament\Tables\Table;
use Illuminate\Support\Collection;
class SupervisorsTable
{
public static function configure(Table $table): Table
{
return $table
->striped()
->recordAction(null)
->poll('10s')
->columns([
Split::make([
TextColumn::make('id')->badge()->alignCenter(),
TextColumn::make('provider.name')
->color(fn ($record): string => match ($record->provider_id) {
1 => 'danger',
8 => 'danger',
2 => 'success',
11 => 'info',
default => 'warning',
}),
Stack::make([
SelectColumn::make('name')
->selectablePlaceholder(true)
->hidden(function (ListSupervisors $livewire) {
return $livewire->tableFilters['provider_id']['value'] == 8;
})
->options(function ($record) {
switch ($record->provider_id) {
case 1:
case 3:
case 4:
case 5:
case 6:
return [
'Fixtures' => 'Fixtures',
'Odds' => 'Odds',
'Countries' => 'Countries',
'Groups' => 'Groups',
'Major Groups' => 'Major Groups',
];
case 2:
return [
'Fixtures' => 'Fixtures',
'Odds' => 'Odds',
'Willhill' => 'Willhill',
'Bwin' => 'Bwin',
'Bet365' => 'Bet365',
'Betfair' => 'Betfair',
];
case 7:
/**
* functions for services
*/
return [
'Txodds Markets' => 'Txodds Markets',
'Txodds Flags' => 'Txodds Flags',
'DB Mapper' => 'DB Mapper',
'Generate Setting' => 'Generate Setting',
'Generate Alarms' => 'Generate Alarms',
'Notify Alarms' => 'Notify Alarms',
];
case 9:
case 10:
return [
'GRAPPER DIRCET' => 'GRAPPER DIRCET',
];
case 11:
return [
'Bet365' => 'Bet365',
'MAGLOO KENIA' => 'MAGLOO KENIA',
'MAGLOO NIGERIA' => 'MAGLOO NIGERIA',
'LOGIFUTURE NIGERA' => 'LOGIFUTURE NIGERA',
'LOGIFUTURE COLOMBIA' => 'LOGIFUTURE COLOMBIA',
];
default:
return [];
}
}),
SelectColumn::make('sport_id')
->hidden(function (ListSupervisors $livewire) {
return $livewire->tableFilters['provider_id']['value'] == 11;
})
->options(fn () => Sport::where('is_active', 1)->pluck('name', 'id'))
->placeholder('All'),
SelectColumn::make('txodds_market_id')
->visible(function (ListSupervisors $livewire) {
return $livewire->tableFilters['provider_id']['value'] == 8;
})
->options(function ($record) {
switch ($record->sport_id) {
case 1:
return TxoddsMarket::where('soccer', 1)->pluck('name', 'market_id');
case 2:
return TxoddsMarket::where('ice_hockey', 1)->pluck('name', 'market_id');
case 3:
return TxoddsMarket::where('basketball', 1)->pluck('name', 'market_id');
case 5:
return TxoddsMarket::where('tennis', 1)->pluck('name', 'market_id');
}
})
->placeholder('All Markets'),
])->space(3),
Stack::make([
TextInputColumn::make('days_from')->prefix('Days Fr')
->hidden(function (ListSupervisors $livewire) {
return in_array($livewire->tableFilters['provider_id']['value'], [7, 8, 11]);
}),
TextInputColumn::make('days_to')->prefix('Days To')
->hidden(function (ListSupervisors $livewire) {
return in_array($livewire->tableFilters['provider_id']['value'], [7, 8, 11]);
}),
])->space(3),
Stack::make([
TextColumn::make('lastcall')
->prefix('Lastcall: ')
->badge()
->color(fn ($state): string => ($state > 0 && $state > time() - 300) ? 'success' : 'danger')
->dateTime()
->visible(function (ListSupervisors $livewire) {
return $livewire->tableFilters['provider_id']['value'] == 8;
}),
TextInputColumn::make('sleep')->prefix('Seep'),
TextInputColumn::make('commandline_options')->prefix('Bash')
->tooltip('command used in supervisor script')
->hidden(function (ListSupervisors $livewire) {
return $livewire->tableFilters['provider_id']['value'] == 8;
}),
])->space(3),
SelectColumn::make('is_supervisor')
->allowOptionsHtml()
->native(false)
->options([
'0' => '<span class="text-amber-500">Cronjob</span>',
'1' => '<span class="text-blue-500">Supervisor</span>',
]),
ToggleColumn::make('is_active')->label('Active')->tooltip(('On/Off'))->onColor('success')->offColor('danger'),
TextColumn::make('runtime')->badge()->prefix('Runtime: '),
]),
])
->filters([
SelectFilter::make('provider_id')
->relationship('provider', 'name')
->label('Provider'),
SelectFilter::make('sport_id')
->relationship('sport', 'name')
->label('Sport'),
TernaryFilter::make('is_supervisor')->label('Run by supervisor'),
TernaryFilter::make('is_active'),
], layout: FiltersLayout::AboveContent)
->deferFilters(false)
->recordActions([
EditAction::make()->hiddenLabel(),
DeleteAction::make()->hiddenLabel(),
])
->toolbarActions([
BulkActionGroup::make([
BulkAction::make('sleep')
->label('Sleep')
->icon('phosphor-timer')
->action(function (Collection $records, array $data): void {
foreach ($records as $record) {
Supervisor::where('id', '=', $record->id)
->update(
['sleep' => $data['sleep']]
);
}
})
->form([
TextInput::make('sleep')->hiddenLabel()->prefix('Sleep'),
]),
BulkAction::make('Switch On')
->icon('phosphor-play')
->action(function (Collection $records): void {
foreach ($records as $record) {
Supervisor::where('id', '=', $record->id)
->update(
['is_active' => 1]
);
}
}),
BulkAction::make('Switch Off')
->icon('phosphor-stop')
->action(function (Collection $records): void {
foreach ($records as $record) {
Supervisor::where('id', '=', $record->id)
->update(
['is_active' => 0]
);
}
}),
BulkAction::make('As supervisor')
->icon('phosphor-play')
->action(function (Collection $records): void {
foreach ($records as $record) {
Supervisor::where('id', '=', $record->id)
->update(
['is_supervisor' => 1]
);
}
}),
BulkAction::make('Not as supervisor')
->icon('phosphor-stop')
->action(function (Collection $records): void {
foreach ($records as $record) {
Supervisor::where('id', '=', $record->id)
->update(
['is_supervisor' => 0]
);
}
}),
DeleteBulkAction::make(),
]),
]);
}
}